You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by jo...@apache.org on 2017/07/31 14:10:20 UTC

[05/25] ambari git commit: AMBARI-21576. Livy2 server startup failure if webhdfs not enabled (Ferenc Schneider via adoroszlai)

AMBARI-21576. Livy2 server startup failure if webhdfs not enabled (Ferenc Schneider via adoroszlai)


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

Branch: refs/heads/branch-feature-AMBARI-21450
Commit: 187c9151146bf0368c379e073ad63b093113d61b
Parents: 7756f98
Author: Ferenc Schneider <fs...@hortonworks.com>
Authored: Wed Jul 26 18:58:19 2017 +0200
Committer: Attila Doroszlai <ad...@hortonworks.com>
Committed: Wed Jul 26 18:58:19 2017 +0200

----------------------------------------------------------------------
 .../common-services/SPARK2/2.0.0/package/scripts/livy2_server.py   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ambari/blob/187c9151/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/livy2_server.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/livy2_server.py b/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/livy2_server.py
index cb4f5ee..50b9cf1 100644
--- a/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/livy2_server.py
+++ b/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/livy2_server.py
@@ -117,7 +117,7 @@ class LivyServer(Script):
         dir_exists = ('FileStatus' in list_status)
       else:
         # have to do time expensive hdfs dfs -d check.
-        dfs_ret_code = shell.call(format("hdfs --config {hadoop_conf_dir} dfs -test -d " + dir_path), user=params.livy_user)[0]
+        dfs_ret_code = shell.call(format("hdfs --config {hadoop_conf_dir} dfs -test -d " + dir_path), user=params.livy2_user)[0]
         dir_exists = not dfs_ret_code #dfs -test -d returns 0 in case the dir exists
 
       if not dir_exists: