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 <[email protected]> Reviewers: Ewen Cheslack-Postava <[email protected]> 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 <[email protected]> Authored: Wed Jun 14 16:23:29 2017 -0700 Committer: Ewen Cheslack-Postava <[email protected]> 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")
