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 in 0.10.2
Date Tue, 09 May 2017 21:21:02 GMT
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 <konstantine@confluent.io>

Reviewers: Jason Gustafson <jason@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 <konstantine@confluent.io>
Authored: Tue May 9 14:20:49 2017 -0700
Committer: Jason Gustafson <jason@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")


Mime
View raw message