Repository: kafka Updated Branches: refs/heads/0.9.0 c5965820a -> d04a918a2
MINOR: Increase timeouts for Kafka Connect system test service to make tests more reliable on wimpy nodes. Author: Ewen Cheslack-Postava <m...@ewencp.org> Reviewers: Gwen Shapira Closes #514 from ewencp/connect-systest-generous-timeouts Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/d04a918a Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/d04a918a Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/d04a918a Branch: refs/heads/0.9.0 Commit: d04a918a239b6d894f71975b6e1e6dcc390424a3 Parents: c596582 Author: Ewen Cheslack-Postava <m...@ewencp.org> Authored: Thu Nov 12 11:35:18 2015 -0800 Committer: Gwen Shapira <csh...@gmail.com> Committed: Thu Nov 12 11:35:18 2015 -0800 ---------------------------------------------------------------------- tests/kafkatest/services/connect.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/d04a918a/tests/kafkatest/services/connect.py ---------------------------------------------------------------------- diff --git a/tests/kafkatest/services/connect.py b/tests/kafkatest/services/connect.py index fbac565..8414092 100644 --- a/tests/kafkatest/services/connect.py +++ b/tests/kafkatest/services/connect.py @@ -58,7 +58,7 @@ class ConnectServiceBase(Service): for pid in pids: node.account.signal(pid, sig, allow_fail=False) for pid in pids: - wait_until(lambda: not node.account.alive(pid), timeout_sec=10, err_msg="Kafka Connect standalone process took too long to exit") + wait_until(lambda: not node.account.alive(pid), timeout_sec=60, err_msg="Kafka Connect standalone process took too long to exit") node.account.ssh("rm -f /mnt/connect.pid", allow_fail=False) @@ -149,7 +149,7 @@ class ConnectStandaloneService(ConnectServiceBase): node.account.ssh("/opt/%s/bin/connect-standalone.sh /mnt/connect.properties " % kafka_dir(node) + " ".join(remote_connector_configs) + " 1>> /mnt/connect.log 2>> /mnt/connect.log & echo $! > /mnt/connect.pid") - monitor.wait_until('Kafka Connect started', timeout_sec=10, err_msg="Never saw message indicating Kafka Connect finished startup") + monitor.wait_until('Kafka Connect started', timeout_sec=15, err_msg="Never saw message indicating Kafka Connect finished startup") if len(self.pids(node)) == 0: raise RuntimeError("No process ids recorded") @@ -173,7 +173,7 @@ class ConnectDistributedService(ConnectServiceBase): cmd = "/opt/%s/bin/connect-distributed.sh /mnt/connect.properties " % kafka_dir(node) cmd += " 1>> /mnt/connect.log 2>> /mnt/connect.log & echo $! > /mnt/connect.pid" node.account.ssh(cmd) - monitor.wait_until('Kafka Connect started', timeout_sec=10, err_msg="Never saw message indicating Kafka Connect finished startup") + monitor.wait_until('Kafka Connect started', timeout_sec=15, err_msg="Never saw message indicating Kafka Connect finished startup") if len(self.pids(node)) == 0: raise RuntimeError("No process ids recorded")
