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/11/21 14:25:48 UTC
kafka git commit: HOTFIX: Increased wait time
Repository: kafka
Updated Branches:
refs/heads/0.10.1 f7795a525 -> c8f70742e
HOTFIX: Increased wait time
Author: Eno Thereska <en...@gmail.com>
Reviewers: Ismael Juma <is...@juma.me.uk>
Closes #2154 from enothereska/hotfix_streams
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/c8f70742
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/c8f70742
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/c8f70742
Branch: refs/heads/0.10.1
Commit: c8f70742e85eee38bf0749ba79d1be73a042c635
Parents: f7795a5
Author: Eno Thereska <en...@gmail.com>
Authored: Mon Nov 21 14:25:38 2016 +0000
Committer: Ismael Juma <is...@juma.me.uk>
Committed: Mon Nov 21 14:25:38 2016 +0000
----------------------------------------------------------------------
tests/kafkatest/services/streams.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/c8f70742/tests/kafkatest/services/streams.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/services/streams.py b/tests/kafkatest/services/streams.py
index 0fea33a..a63810e 100644
--- a/tests/kafkatest/services/streams.py
+++ b/tests/kafkatest/services/streams.py
@@ -91,7 +91,7 @@ class StreamsSmokeTestBaseService(KafkaPathResolverMixin, Service):
def wait(self):
for node in self.nodes:
for pid in self.pids(node):
- wait_until(lambda: not node.account.alive(pid), timeout_sec=180, err_msg="Streams Smoke Test process on " + str(node.account) + " took too long to exit")
+ wait_until(lambda: not node.account.alive(pid), timeout_sec=360, err_msg="Streams Smoke Test process on " + str(node.account) + " took too long to exit")
def clean_node(self, node):
node.account.kill_process("streams", clean_shutdown=False, allow_fail=True)