kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: HOTFIX: Increased wait time
Date Mon, 21 Nov 2016 14:25:48 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.1 f7795a525 -> c8f70742e


HOTFIX: Increased wait time

Author: Eno Thereska <eno.thereska@gmail.com>

Reviewers: Ismael Juma <ismael@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 <eno.thereska@gmail.com>
Authored: Mon Nov 21 14:25:38 2016 +0000
Committer: Ismael Juma <ismael@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)


Mime
View raw message