kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gwens...@apache.org
Subject kafka git commit: MINOR: Increase timeouts for Kafka Connect system test service to make tests more reliable on wimpy nodes.
Date Thu, 12 Nov 2015 19:35:28 GMT
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 <me@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 <me@ewencp.org>
Authored: Thu Nov 12 11:35:18 2015 -0800
Committer: Gwen Shapira <cshapi@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")


Mime
View raw message