You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ew...@apache.org on 2017/06/14 23:23:37 UTC
kafka git commit: KAFKA-5450: Increased timeout of Connect system
test utilities
Repository: kafka
Updated Branches:
refs/heads/trunk 005b86ecf -> bcf5da0ba
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 <rh...@gmail.com>
Reviewers: Ewen Cheslack-Postava <ew...@confluent.io>
Closes #3344 from rhauch/KAFKA-5450
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/bcf5da0b
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/bcf5da0b
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/bcf5da0b
Branch: refs/heads/trunk
Commit: bcf5da0baccc6bf9baa2a45047845dc6842cd200
Parents: 005b86e
Author: Randall Hauch <rh...@gmail.com>
Authored: Wed Jun 14 16:23:29 2017 -0700
Committer: Ewen Cheslack-Postava <me...@ewencp.org>
Committed: Wed Jun 14 16:23:29 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/bcf5da0b/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")