You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2016/12/19 23:39:36 UTC
kafka git commit: KAFKA-4166;
Fix transient MM failure caused by slow old consumer shutdown
Repository: kafka
Updated Branches:
refs/heads/trunk bc9ef716a -> 529ca3293
KAFKA-4166; Fix transient MM failure caused by slow old consumer shutdown
Author: Jason Gustafson <ja...@confluent.io>
Reviewers: Ismael Juma <is...@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 <ja...@confluent.io>
Authored: Mon Dec 19 23:39:35 2016 +0000
Committer: Ismael Juma <is...@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):