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 <vbrodets...@cybervisiontech.com>
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
vbrodets...@apache.org.

Reply via email to