Repository: kafka Updated Branches: refs/heads/0.10.2 0e8b08477 -> bce189fa4
HOTFIX: Increase kafkatest startup wait time on ConnectDistributed service in 0.10.2 Author: Konstantine Karantasis <[email protected]> Reviewers: Jason Gustafson <[email protected]> Closes #3007 from kkonstantine/HOTFIX-Align-startup-wait-time-for-ConnectDistributed-service-with-ConnectStandalone-in-kafkatests-0.10.2 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/bce189fa Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/bce189fa Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/bce189fa Branch: refs/heads/0.10.2 Commit: bce189fa451141df9f5b1c86a307a321caeaf807 Parents: 0e8b084 Author: Konstantine Karantasis <[email protected]> Authored: Tue May 9 14:20:49 2017 -0700 Committer: Jason Gustafson <[email protected]> Committed: Tue May 9 14:20:49 2017 -0700 ---------------------------------------------------------------------- tests/kafkatest/services/connect.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/bce189fa/tests/kafkatest/services/connect.py ---------------------------------------------------------------------- diff --git a/tests/kafkatest/services/connect.py b/tests/kafkatest/services/connect.py index 5a8581a..a27acd7 100644 --- a/tests/kafkatest/services/connect.py +++ b/tests/kafkatest/services/connect.py @@ -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=15, err_msg="Never saw message indicating Kafka Connect finished startup on " + str(node.account)) + monitor.wait_until('Kafka Connect started', timeout_sec=30, 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")
