kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: KAFKA-5450: Increased timeout of Connect system test utilities
Date Wed, 14 Jun 2017 23:23:44 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.11.0 ad0acb6c7 -> d199f2de7


KAFKA-5450: Increased timeout of Connect system test utilities

Increased the timeout from 30sec to 60sec. When running the system tests with packaged Kafka,
Connect workers can take about 30seconds to start.

Author: Randall Hauch <rhauch@gmail.com>

Reviewers: Ewen Cheslack-Postava <ewen@confluent.io>

Closes #3344 from rhauch/KAFKA-5450

(cherry picked from commit bcf5da0baccc6bf9baa2a45047845dc6842cd200)
Signed-off-by: Ewen Cheslack-Postava <me@ewencp.org>


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/d199f2de
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/d199f2de
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/d199f2de

Branch: refs/heads/0.11.0
Commit: d199f2de71698dff457053a5efec408a2950647e
Parents: ad0acb6
Author: Randall Hauch <rhauch@gmail.com>
Authored: Wed Jun 14 16:23:29 2017 -0700
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Wed Jun 14 16:23:41 2017 -0700

----------------------------------------------------------------------
 tests/kafkatest/services/connect.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/d199f2de/tests/kafkatest/services/connect.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/services/connect.py b/tests/kafkatest/services/connect.py
index a27acd7..399e53c 100644
--- a/tests/kafkatest/services/connect.py
+++ b/tests/kafkatest/services/connect.py
@@ -233,7 +233,7 @@ class ConnectStandaloneService(ConnectServiceBase):
             cmd = self.start_cmd(node, remote_connector_configs)
             self.logger.debug("Connect standalone command: %s", cmd)
             node.account.ssh(cmd)
-            monitor.wait_until('Kafka Connect started', timeout_sec=30, err_msg="Never saw
message indicating Kafka Connect finished startup on " + str(node.account))
+            monitor.wait_until('Kafka Connect started', timeout_sec=60, 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")
@@ -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=30, err_msg="Never saw
message indicating Kafka Connect finished startup on " + str(node.account))
+            monitor.wait_until('Kafka Connect started', timeout_sec=60, 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