You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by mp...@apache.org on 2015/09/21 20:49:38 UTC
ambari git commit: AMBARI-13172. Kafka Service check fails with umask
027 on secure cluster. (mpapirkovskyy)
Repository: ambari
Updated Branches:
refs/heads/trunk d278ed1a2 -> 2d12f1ede
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/2d12f1ed
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/2d12f1ed
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/2d12f1ed
Branch: refs/heads/trunk
Commit: 2d12f1edec147f317f55345531b200e5d4f7d9fe
Parents: d278ed1
Author: Myroslav Papirkovskyy <mp...@hortonworks.com>
Authored: Mon Sep 21 21:49:39 2015 +0300
Committer: Myroslav Papirkovskyy <mp...@hortonworks.com>
Committed: Mon Sep 21 21:49:39 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/2d12f1ed/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