Repository: ambari
Updated Branches:
  refs/heads/branch-2.6 db67f0385 -> faef3a22e


AMBARI-22229.Handle upload of interpreter.json to remote storage in 
Ambari(Prabhjyot Singh via Venkata Sairam)


Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/faef3a22
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/faef3a22
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/faef3a22

Branch: refs/heads/branch-2.6
Commit: faef3a22ed2801f4e931074045b37f691bd9977f
Parents: db67f03
Author: Venkata Sairam <[email protected]>
Authored: Fri Oct 13 15:23:33 2017 +0530
Committer: Venkata Sairam <[email protected]>
Committed: Fri Oct 13 15:23:33 2017 +0530

----------------------------------------------------------------------
 .../common-services/ZEPPELIN/0.7.0/package/scripts/master.py      | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ambari/blob/faef3a22/ambari-server/src/main/resources/common-services/ZEPPELIN/0.7.0/package/scripts/master.py
----------------------------------------------------------------------
diff --git 
a/ambari-server/src/main/resources/common-services/ZEPPELIN/0.7.0/package/scripts/master.py
 
b/ambari-server/src/main/resources/common-services/ZEPPELIN/0.7.0/package/scripts/master.py
index a8b1b32..6a84d79 100644
--- 
a/ambari-server/src/main/resources/common-services/ZEPPELIN/0.7.0/package/scripts/master.py
+++ 
b/ambari-server/src/main/resources/common-services/ZEPPELIN/0.7.0/package/scripts/master.py
@@ -305,7 +305,8 @@ class Master(Script):
   def get_zeppelin_conf_FS_directory(self, params):
     hdfs_interpreter_config = 
params.config['configurations']['zeppelin-config']['zeppelin.config.fs.dir']
 
-    if not hdfs_interpreter_config.startswith("/"):
+    # if it doesn't start from "/" or doesn't contains "://" as in hdfs://, 
file://, etc then make it a absolute path
+    if not (hdfs_interpreter_config.startswith("/") or '://' in 
hdfs_interpreter_config):
       hdfs_interpreter_config = "/user/" + format("{zeppelin_user}") + "/" + 
hdfs_interpreter_config
 
     return hdfs_interpreter_config

Reply via email to