You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by mr...@apache.org on 2017/11/17 20:40:24 UTC
ambari git commit: AMBARI-22468 : enabling hdfs and hive ranger
plugin fails (mradhakrishnan)
Repository: ambari
Updated Branches:
refs/heads/branch-2.6 c09c69b2f -> a1d59b7dd
AMBARI-22468 : enabling hdfs and hive ranger plugin fails (mradhakrishnan)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/a1d59b7d
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/a1d59b7d
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/a1d59b7d
Branch: refs/heads/branch-2.6
Commit: a1d59b7dde13b8e3cad5a1e1687911ca4afc340b
Parents: c09c69b
Author: Madhuvanthi Radhakrishnan <mr...@hortonworks.com>
Authored: Fri Nov 17 12:39:07 2017 -0800
Committer: Madhuvanthi Radhakrishnan <mr...@hortonworks.com>
Committed: Fri Nov 17 12:40:21 2017 -0800
----------------------------------------------------------------------
.../resources/stacks/HDP/2.6/services/stack_advisor.py | 11 ++++++-----
1 file changed, 6 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ambari/blob/a1d59b7d/ambari-server/src/main/resources/stacks/HDP/2.6/services/stack_advisor.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/stacks/HDP/2.6/services/stack_advisor.py b/ambari-server/src/main/resources/stacks/HDP/2.6/services/stack_advisor.py
index a16fdb7..a5f54a3 100644
--- a/ambari-server/src/main/resources/stacks/HDP/2.6/services/stack_advisor.py
+++ b/ambari-server/src/main/resources/stacks/HDP/2.6/services/stack_advisor.py
@@ -66,11 +66,12 @@ class HDP26StackAdvisor(HDP25StackAdvisor):
if storm_env and storm_site and security_enabled and 'STREAMLINE' in servicesList:
storm_nimbus_impersonation_acl = storm_site["nimbus.impersonation.acl"] if "nimbus.impersonation.acl" in storm_site else None
streamline_env = self.getServicesSiteProperties(services, "streamline-env")
- _streamline_principal_name = streamline_env['streamline_principal_name'] if 'streamline_principal_name' in streamline_env else None
- if _streamline_principal_name is not None and storm_nimbus_impersonation_acl is not None:
- streamline_bare_principal = get_bare_principal(_streamline_principal_name)
- storm_nimbus_impersonation_acl.replace('{{streamline_bare_principal}}', streamline_bare_principal)
- putStormSiteProperty('nimbus.impersonation.acl', storm_nimbus_impersonation_acl)
+ if streamline_env:
+ _streamline_principal_name = streamline_env['streamline_principal_name'] if 'streamline_principal_name' in streamline_env else None
+ if _streamline_principal_name is not None and storm_nimbus_impersonation_acl is not None:
+ streamline_bare_principal = get_bare_principal(_streamline_principal_name)
+ storm_nimbus_impersonation_acl.replace('{{streamline_bare_principal}}', streamline_bare_principal)
+ putStormSiteProperty('nimbus.impersonation.acl', storm_nimbus_impersonation_acl)
storm_nimbus_autocred_plugin_classes = storm_site["nimbus.autocredential.plugins.classes"] if "nimbus.autocredential.plugins.classes" in storm_site else None
if storm_nimbus_autocred_plugin_classes is not None: