ambari-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From swa...@apache.org
Subject ambari git commit: AMBARI-10056. Kafka service check fails after adding Kafka via Add Services. (Sriharsha Chintalapani via swagle)
Date Fri, 13 Mar 2015 03:58:49 GMT
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 <swagle@hortonworks.com>
Authored: Thu Mar 12 20:58:36 2015 -0700
Committer: Siddharth Wagle <swagle@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)


Mime
View raw message