This is an automated email from the ASF dual-hosted git repository.
vbrodetskyi pushed a commit to branch branch-2.6
in repository https://gitbox.apache.org/repos/asf/ambari.git
The following commit(s) were added to refs/heads/branch-2.6 by this push:
new ef1aace [AMBARI-23161] Invalid storage property value for zeppelin in
stack H… (#568)
ef1aace is described below
commit ef1aace01ed1181c5ede4950d7551cd3aead019c
Author: vbrodetskyi <[email protected]>
AuthorDate: Wed Mar 7 16:17:06 2018 +0200
[AMBARI-23161] Invalid storage property value for zeppelin in stack H…
(#568)
* [AMBARI-23161] Invalid storage property value for zeppelin in stack HDP
2.6
* [AMBARI-23161] Invalid storage property value for zeppelin in stack HDP
2.6
---
.../resources/stacks/HDP/2.6/services/stack_advisor.py | 14 +++++++++++++-
1 file changed, 13 insertions(+), 1 deletion(-)
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 0c6c2c7..27558cb 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
@@ -21,6 +21,7 @@ import json
import math
import re
from resource_management.libraries.functions import format
+from resource_management.libraries.functions.version import compare_versions
class HDP26StackAdvisor(HDP25StackAdvisor):
@@ -72,7 +73,7 @@ class HDP26StackAdvisor(HDP25StackAdvisor):
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:
new_storm_nimbus_autocred_plugin_classes =
['org.apache.storm.hdfs.security.AutoHDFS',
@@ -117,6 +118,17 @@ class HDP26StackAdvisor(HDP25StackAdvisor):
:type hosts dict
"""
super(HDP26StackAdvisor,
self).recommendZeppelinConfigurations(configurations, clusterData, services,
hosts)
+
+ cluster_env = self.getServicesSiteProperties(services, "cluster-env")
+ if cluster_env and "recommendations_full_stack_version" in cluster_env:
+ full_stack_version = cluster_env["recommendations_full_stack_version"]
+ if compare_versions(full_stack_version, '2.6.3.0') >= 0:
+ zeppelin_config = self.getServicesSiteProperties(services,
"zeppelin-config")
+ if zeppelin_config and
zeppelin_config.get('zeppelin.notebook.storage', None) ==
'org.apache.zeppelin.notebook.repo.VFSNotebookRepo':
+ putZeppelinConfigProperty = self.putProperty(configurations,
'zeppelin-config', services)
+ putZeppelinConfigProperty('zeppelin.notebook.storage',
'org.apache.zeppelin.notebook.repo.FileSystemNotebookRepo')
+
+
self.__addZeppelinToLivy2SuperUsers(configurations, services)
def recommendAtlasConfigurations(self, configurations, clusterData,
services, hosts):
--
To stop receiving notification emails like this one, please contact
[email protected].
