You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2017/05/09 21:21:02 UTC
kafka git commit: HOTFIX: Increase kafkatest startup wait time on
ConnectDistributed service in 0.10.2
Repository: kafka
Updated Branches:
refs/heads/0.10.2 0e8b08477 -> bce189fa4
HOTFIX: Increase kafkatest startup wait time on ConnectDistributed service in 0.10.2
Author: Konstantine Karantasis <ko...@confluent.io>
Reviewers: Jason Gustafson <ja...@confluent.io>
Closes #3007 from kkonstantine/HOTFIX-Align-startup-wait-time-for-ConnectDistributed-service-with-ConnectStandalone-in-kafkatests-0.10.2
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/bce189fa
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/bce189fa
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/bce189fa
Branch: refs/heads/0.10.2
Commit: bce189fa451141df9f5b1c86a307a321caeaf807
Parents: 0e8b084
Author: Konstantine Karantasis <ko...@confluent.io>
Authored: Tue May 9 14:20:49 2017 -0700
Committer: Jason Gustafson <ja...@confluent.io>
Committed: Tue May 9 14:20:49 2017 -0700
----------------------------------------------------------------------
tests/kafkatest/services/connect.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/bce189fa/tests/kafkatest/services/connect.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/services/connect.py b/tests/kafkatest/services/connect.py
index 5a8581a..a27acd7 100644
--- a/tests/kafkatest/services/connect.py
+++ b/tests/kafkatest/services/connect.py
@@ -272,7 +272,7 @@ class ConnectDistributedService(ConnectServiceBase):
cmd = self.start_cmd(node)
self.logger.debug("Connect distributed command: %s", cmd)
node.account.ssh(cmd)
- monitor.wait_until('Kafka Connect started', timeout_sec=15, err_msg="Never saw message indicating Kafka Connect finished startup on " + str(node.account))
+ monitor.wait_until('Kafka Connect started', timeout_sec=30, err_msg="Never saw message indicating Kafka Connect finished startup on " + str(node.account))
if len(self.pids(node)) == 0:
raise RuntimeError("No process ids recorded")