kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: KAFKA-2573: Mirror maker system test hangs and eventually fails
Date Tue, 06 Oct 2015 21:06:53 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk b46cb3b29 -> a0ca8f642


KAFKA-2573: Mirror maker system test hangs and eventually fails

Author: Ashish Singh <asingh@cloudera.com>

Reviewers: Geoff Anderson, Guozhang Wang

Closes #234 from SinghAsDev/KAFKA-2573


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

Branch: refs/heads/trunk
Commit: a0ca8f6422e031c58e3a832852ba105e0f2efbad
Parents: b46cb3b
Author: Ashish Singh <asingh@cloudera.com>
Authored: Tue Oct 6 14:11:06 2015 -0700
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Tue Oct 6 14:11:06 2015 -0700

----------------------------------------------------------------------
 tests/kafkatest/sanity_checks/test_mirror_maker.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/a0ca8f64/tests/kafkatest/sanity_checks/test_mirror_maker.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/sanity_checks/test_mirror_maker.py b/tests/kafkatest/sanity_checks/test_mirror_maker.py
index 3481d7a..0b0eca3 100644
--- a/tests/kafkatest/sanity_checks/test_mirror_maker.py
+++ b/tests/kafkatest/sanity_checks/test_mirror_maker.py
@@ -77,9 +77,9 @@ class TestMirrorMakerService(Test):
             "grep \"consumer\.timeout\.ms\" %s" % MirrorMaker.CONSUMER_CONFIG, allow_fail=False)
 
         self.producer.start()
-        self.producer.wait()
+        self.producer.wait(10)
         self.consumer.start()
-        self.consumer.wait()
+        self.consumer.wait(10)
 
         num_consumed = len(self.consumer.messages_consumed[1])
         num_produced = self.producer.num_acked


Mime
View raw message