Repository: ambari Updated Branches: refs/heads/trunk 86ed53e74 -> f5dafcfe2
AMBARI-19539. Spark2 Service check fails on WE enabled cluster (Bikas Saha via smohanty) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/f5dafcfe Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/f5dafcfe Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/f5dafcfe Branch: refs/heads/trunk Commit: f5dafcfe218f55e197c90168ae6ac9738f1c99df Parents: 86ed53e Author: Sumit Mohanty <[email protected]> Authored: Fri Jan 13 15:43:01 2017 -0800 Committer: Sumit Mohanty <[email protected]> Committed: Fri Jan 13 15:43:01 2017 -0800 ---------------------------------------------------------------------- .../common-services/SPARK2/2.0.0/package/scripts/params.py | 5 ++++- .../SPARK2/2.0.0/package/scripts/service_check.py | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/f5dafcfe/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/params.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/params.py b/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/params.py index 920b048..c19f88c 100755 --- a/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/params.py +++ b/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/params.py @@ -112,10 +112,13 @@ else: ui_ssl_enabled = default("configurations/spark2-defaults/spark.ssl.enabled", False) spark_yarn_historyServer_address = default(spark_history_server_host, "localhost") - +spark_history_scheme = "http" spark_history_ui_port = config['configurations']['spark2-defaults']['spark.history.ui.port'] + if ui_ssl_enabled: spark_history_ui_port = str(int(spark_history_ui_port) + 400) + spark_history_scheme = "https" + spark_env_sh = config['configurations']['spark2-env']['content'] spark_log4j_properties = config['configurations']['spark2-log4j-properties']['content'] http://git-wip-us.apache.org/repos/asf/ambari/blob/f5dafcfe/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/service_check.py ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/service_check.py b/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/service_check.py index a27eda2..acd3340 100755 --- a/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/service_check.py +++ b/ambari-server/src/main/resources/common-services/SPARK2/2.0.0/package/scripts/service_check.py @@ -35,7 +35,7 @@ class SparkServiceCheck(Script): livy_kinit_cmd = format("{kinit_path_local} -kt {smoke_user_keytab} {smokeuser_principal}; ") Execute(livy_kinit_cmd, user=params.livy2_user) - Execute(format("curl -s -o /dev/null -w'%{{http_code}}' --negotiate -u: -k http://{spark_history_server_host}:{spark_history_ui_port} | grep 200"), + Execute(format("curl -s -o /dev/null -w'%{{http_code}}' --negotiate -u: -k {spark_history_scheme}://{spark_history_server_host}:{spark_history_ui_port} | grep 200"), tries=5, try_sleep=3, logoutput=True
