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 <[email protected]> Reviewers: Ewen Cheslack-Postava <[email protected]> Closes #3344 from rhauch/KAFKA-5450 (cherry picked from commit bcf5da0baccc6bf9baa2a45047845dc6842cd200) Signed-off-by: Ewen Cheslack-Postava <[email protected]> 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 <[email protected]> Authored: Wed Jun 14 16:23:29 2017 -0700 Committer: Ewen Cheslack-Postava <[email protected]> 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")
