You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by sw...@apache.org on 2015/03/13 04:58:49 UTC
ambari git commit: AMBARI-10056. Kafka service check fails after
adding Kafka via Add Services. (Sriharsha Chintalapani via swagle)
Repository: ambari
Updated Branches:
refs/heads/branch-2.0.0 b07677898 -> d3df7b1a4
AMBARI-10056. Kafka service check fails after adding Kafka via Add Services. (Sriharsha Chintalapani via swagle)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/d3df7b1a
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/d3df7b1a
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/d3df7b1a
Branch: refs/heads/branch-2.0.0
Commit: d3df7b1a4cbe739200f8608c2a6141320529a4d1
Parents: b076778
Author: Siddharth Wagle <sw...@hortonworks.com>
Authored: Thu Mar 12 20:58:36 2015 -0700
Committer: Siddharth Wagle <sw...@hortonworks.com>
Committed: Thu Mar 12 20:58:36 2015 -0700
----------------------------------------------------------------------
.../common-services/KAFKA/0.8.1.2.2/package/scripts/kafka.py | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ambari/blob/d3df7b1a/ambari-server/src/main/resources/common-services/KAFKA/0.8.1.2.2/package/scripts/kafka.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/main/resources/common-services/KAFKA/0.8.1.2.2/package/scripts/kafka.py b/ambari-server/src/main/resources/common-services/KAFKA/0.8.1.2.2/package/scripts/kafka.py
index c75222b..0170116 100644
--- a/ambari-server/src/main/resources/common-services/KAFKA/0.8.1.2.2/package/scripts/kafka.py
+++ b/ambari-server/src/main/resources/common-services/KAFKA/0.8.1.2.2/package/scripts/kafka.py
@@ -27,6 +27,8 @@ def kafka():
import params
Directory([params.kafka_log_dir, params.kafka_pid_dir, params.conf_dir],
+ mode=0755,
+ cd_access='a',
owner=params.kafka_user,
group=params.user_group,
recursive=True
@@ -42,6 +44,8 @@ def kafka():
kafka_data_dir = kafka_server_config['log.dirs']
Directory(filter(None,kafka_data_dir.split(",")),
+ mode=0755,
+ cd_access='a',
owner=params.kafka_user,
group=params.user_group,
recursive=True)