ambari-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From echekans...@apache.org
Subject ambari git commit: AMBARI-20052. Spark2 service check is failing in secure cluster (echekanskiy)
Date Mon, 20 Feb 2017 14:55:01 GMT
Repository: ambari
Updated Branches:
  refs/heads/branch-2.5 f96d43ccc -> 1169694ec


AMBARI-20052. Spark2 service check is failing in secure cluster (echekanskiy)


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

Branch: refs/heads/branch-2.5
Commit: 1169694ecdc77c5f317d105a0c17da6b0b806bdf
Parents: f96d43c
Author: Eugene Chekanskiy <echekanskiy@hortonworks.com>
Authored: Mon Feb 20 16:52:42 2017 +0200
Committer: Eugene Chekanskiy <echekanskiy@hortonworks.com>
Committed: Mon Feb 20 16:52:42 2017 +0200

----------------------------------------------------------------------
 .../common-services/SPARK2/2.0.0/package/scripts/params.py       | 2 ++
 .../SPARK2/2.0.0/package/scripts/service_check.py                | 4 ++--
 2 files changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ambari/blob/1169694e/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 66c6100..e508a0d 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
@@ -135,6 +135,8 @@ security_enabled = config['configurations']['cluster-env']['security_enabled']
 kinit_path_local = get_kinit_path(default('/configurations/kerberos-env/executable_search_paths',
None))
 spark_kerberos_keytab =  config['configurations']['spark2-defaults']['spark.history.kerberos.keytab']
 spark_kerberos_principal =  config['configurations']['spark2-defaults']['spark.history.kerberos.principal']
+smoke_user_keytab = config['configurations']['cluster-env']['smokeuser_keytab']
+smokeuser_principal =  config['configurations']['cluster-env']['smokeuser_principal_name']
 
 spark_thriftserver_hosts = default("/clusterHostInfo/spark2_thriftserver_hosts", [])
 has_spark_thriftserver = not len(spark_thriftserver_hosts) == 0

http://git-wip-us.apache.org/repos/asf/ambari/blob/1169694e/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 bcdf118..e6bd120 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
@@ -32,7 +32,7 @@ class SparkServiceCheck(Script):
     if params.security_enabled:
       spark_kinit_cmd = format("{kinit_path_local} -kt {spark_kerberos_keytab} {spark_principal};
")
       Execute(spark_kinit_cmd, user=params.spark_user)
-      if (params.has_livyserver):
+      if params.has_livyserver:
         livy_kinit_cmd = format("{kinit_path_local} -kt {smoke_user_keytab} {smokeuser_principal};
")
         Execute(livy_kinit_cmd, user=params.livy2_user)
 
@@ -42,7 +42,7 @@ class SparkServiceCheck(Script):
             logoutput=True
             )
     if params.has_livyserver:
-      live_livyserver_host = "";
+      live_livyserver_host = ""
       for livyserver_host in params.livy2_livyserver_hosts:
         try:
           Execute(format("curl -s -o /dev/null -w'%{{http_code}}' --negotiate -u: -k http://{livyserver_host}:{livy2_livyserver_port}/sessions
| grep 200"),


Mime
View raw message