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 05:04:18 UTC
ambari git commit: AMBARI-10056. Kafka service check fails after
adding Kafka via Add Services. Fixed unit test. (swagle)
Repository: ambari
Updated Branches:
refs/heads/branch-2.0.0 d3df7b1a4 -> 8d130de75
AMBARI-10056. Kafka service check fails after adding Kafka via Add Services. Fixed unit test. (swagle)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/8d130de7
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/8d130de7
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/8d130de7
Branch: refs/heads/branch-2.0.0
Commit: 8d130de7528ae71db1a79e6f87e9e0b94d1a430c
Parents: d3df7b1
Author: Siddharth Wagle <sw...@hortonworks.com>
Authored: Thu Mar 12 21:03:57 2015 -0700
Committer: Siddharth Wagle <sw...@hortonworks.com>
Committed: Thu Mar 12 21:03:57 2015 -0700
----------------------------------------------------------------------
.../test/python/stacks/2.2/KAFKA/test_kafka_broker.py | 12 +++++++++---
1 file changed, 9 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ambari/blob/8d130de7/ambari-server/src/test/python/stacks/2.2/KAFKA/test_kafka_broker.py
----------------------------------------------------------------------
diff --git a/ambari-server/src/test/python/stacks/2.2/KAFKA/test_kafka_broker.py b/ambari-server/src/test/python/stacks/2.2/KAFKA/test_kafka_broker.py
index f157308..a8b6693 100644
--- a/ambari-server/src/test/python/stacks/2.2/KAFKA/test_kafka_broker.py
+++ b/ambari-server/src/test/python/stacks/2.2/KAFKA/test_kafka_broker.py
@@ -36,17 +36,23 @@ class TestKafkaBroker(RMFTestCase):
self.assertResourceCalled('Directory', '/var/log/kafka',
owner = 'kafka',
group = 'hadoop',
- recursive = True
+ recursive = True,
+ mode = 0755,
+ cd_access = 'a'
)
self.assertResourceCalled('Directory', '/var/run/kafka',
owner = 'kafka',
group = 'hadoop',
- recursive = True
+ recursive = True,
+ mode = 0755,
+ cd_access = 'a'
)
self.assertResourceCalled('Directory', '/etc/kafka/conf',
owner = 'kafka',
group = 'hadoop',
- recursive = True
+ recursive = True,
+ mode = 0755,
+ cd_access = 'a'
)