kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject kafka git commit: HOTFIX: Increase kafkatest startup wait time on ConnectDistributed service
Date Tue, 09 May 2017 21:03:37 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk c69842336 -> 8ace736f7


HOTFIX: Increase kafkatest startup wait time on ConnectDistributed service

Author: Konstantine Karantasis <konstantine@confluent.io>

Reviewers: Magesh Nandakumar <magesh.n.kumar@gmail.com>, Jason Gustafson <jason@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 <konstantine@confluent.io>
Authored: Tue May 9 14:02:30 2017 -0700
Committer: Jason Gustafson <jason@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")


Mime
View raw message