ambari-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mpapirkovs...@apache.org
Subject ambari git commit: AMBARI-13172. Kafka Service check fails with umask 027 on secure cluster. (mpapirkovskyy)
Date Mon, 21 Sep 2015 18:50:43 GMT
Repository: ambari
Updated Branches:
  refs/heads/branch-2.1.2 a0ea1000d -> 414496b3f


AMBARI-13172. Kafka Service check fails with umask 027 on secure cluster. (mpapirkovskyy)


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

Branch: refs/heads/branch-2.1.2
Commit: 414496b3f8af23b8dd328e9459e29ce56507bb04
Parents: a0ea100
Author: Myroslav Papirkovskyy <mpapyrkovskyy@hortonworks.com>
Authored: Mon Sep 21 21:49:39 2015 +0300
Committer: Myroslav Papirkovskyy <mpapyrkovskyy@hortonworks.com>
Committed: Mon Sep 21 21:50:57 2015 +0300

----------------------------------------------------------------------
 .../KAFKA/0.8.1.2.2/package/scripts/service_check.py               | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ambari/blob/414496b3/ambari-server/src/main/resources/common-services/KAFKA/0.8.1.2.2/package/scripts/service_check.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/KAFKA/0.8.1.2.2/package/scripts/service_check.py
b/ambari-server/src/main/resources/common-services/KAFKA/0.8.1.2.2/package/scripts/service_check.py
index d8acd4a..bcf62c5 100644
--- a/ambari-server/src/main/resources/common-services/KAFKA/0.8.1.2.2/package/scripts/service_check.py
+++ b/ambari-server/src/main/resources/common-services/KAFKA/0.8.1.2.2/package/scripts/service_check.py
@@ -40,7 +40,7 @@ class ServiceCheck(Script):
     command = source_cmd + " ; " + create_topic_cmd
 
     Logger.info("Running kafka create topic command: %s" % command)
-    call_and_match_output(command, format("({create_topic_cmd_created_output})|({create_topic_cmd_exists_output})"),
"Failed to check that topic exists")
+    call_and_match_output(command, format("({create_topic_cmd_created_output})|({create_topic_cmd_exists_output})"),
"Failed to check that topic exists", user=params.kafka_user)
 
   def read_kafka_config(self):
     import params


Mime
View raw message