[ambari] branch trunk updated: [AMBARI-23161] Invalid storage property value for zeppelin in stack HDP 2.6 (#646)

[vbrodetskyi]

This is an automated email from the ASF dual-hosted git repository.

vbrodetskyi pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/ambari.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 7a267d2  [AMBARI-23161] Invalid storage property value for zeppelin in 
stack HDP 2.6 (#646)
7a267d2 is described below

commit 7a267d21eb1dd636be0e4563bba3046ca0d89dd3
Author: vbrodetskyi <vbrodets...@cybervisiontech.com>
AuthorDate: Wed Mar 14 01:28:03 2018 +0200

    [AMBARI-23161] Invalid storage property value for zeppelin in stack HDP 2.6 
(#646)
---
 .../main/resources/stacks/HDP/2.6/services/stack_advisor.py   | 11 +++++++++++
 1 file changed, 11 insertions(+)

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 6951282..4f9ba1c 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
@@ -20,6 +20,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):
@@ -65,6 +66,16 @@ 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.