kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: KAFKA-4166; Fix transient MM failure caused by slow old consumer shutdown
Date Mon, 19 Dec 2016 23:39:36 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk bc9ef716a -> 529ca3293


KAFKA-4166; Fix transient MM failure caused by slow old consumer shutdown

Author: Jason Gustafson <jason@confluent.io>

Reviewers: Ismael Juma <ismael@juma.me.uk>

Closes #2279 from hachikuji/KAFKA-4166


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

Branch: refs/heads/trunk
Commit: 529ca3293254cc84fef82dbe5931e98129f6dba3
Parents: bc9ef71
Author: Jason Gustafson <jason@confluent.io>
Authored: Mon Dec 19 23:39:35 2016 +0000
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Mon Dec 19 23:39:35 2016 +0000

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


http://git-wip-us.apache.org/repos/asf/kafka/blob/529ca329/tests/kafkatest/services/mirror_maker.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/services/mirror_maker.py b/tests/kafkatest/services/mirror_maker.py
index c056705..55b75d0 100644
--- a/tests/kafkatest/services/mirror_maker.py
+++ b/tests/kafkatest/services/mirror_maker.py
@@ -180,13 +180,13 @@ class MirrorMaker(KafkaPathResolverMixin, Service):
         cmd = self.start_cmd(node)
         self.logger.debug("Mirror maker command: %s", cmd)
         node.account.ssh(cmd, allow_fail=False)
-        wait_until(lambda: self.alive(node), timeout_sec=10, backoff_sec=.5,
+        wait_until(lambda: self.alive(node), timeout_sec=30, backoff_sec=.5,
                    err_msg="Mirror maker took to long to start.")
         self.logger.debug("Mirror maker is alive")
 
     def stop_node(self, node, clean_shutdown=True):
         node.account.kill_process("java", allow_fail=True, clean_shutdown=clean_shutdown)
-        wait_until(lambda: not self.alive(node), timeout_sec=10, backoff_sec=.5,
+        wait_until(lambda: not self.alive(node), timeout_sec=30, backoff_sec=.5,
                    err_msg="Mirror maker took to long to stop.")
 
     def clean_node(self, node):


Mime
View raw message