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:03:37 UTC
kafka git commit: HOTFIX: Increase kafkatest startup wait time on
ConnectDistributed service
Repository: kafka
Updated Branches:
refs/heads/trunk c69842336 -> 8ace736f7
HOTFIX: Increase kafkatest startup wait time on ConnectDistributed service
Author: Konstantine Karantasis <ko...@confluent.io>
Reviewers: Magesh Nandakumar <ma...@gmail.com>, Jason Gustafson <ja...@confluent.io>
Closes #3006 from kkonstantine/HOTFIX-Align-startup-wait-time-for-ConnectDistributed-service-with-ConnectStandalone-in-kafkatests
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/8ace736f
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/8ace736f
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/8ace736f
Branch: refs/heads/trunk
Commit: 8ace736f7121161518953b4ce2a03f36a8306e18
Parents: c698423
Author: Konstantine Karantasis <ko...@confluent.io>
Authored: Tue May 9 14:02:30 2017 -0700
Committer: Jason Gustafson <ja...@confluent.io>
Committed: Tue May 9 14:02:30 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/8ace736f/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")