kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated: MINOR: increase system test kafka start timeout (#5934)
Date Wed, 21 Nov 2018 19:49:50 GMT
This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git

The following commit(s) were added to refs/heads/trunk by this push:
     new 14fbf16  MINOR: increase system test kafka start timeout (#5934)
14fbf16 is described below

commit 14fbf16875f6b1dca9022b5d22aebd4e8bb2b2da
Author: John Roesler <vvcephei@users.noreply.github.com>
AuthorDate: Wed Nov 21 13:49:36 2018 -0600

    MINOR: increase system test kafka start timeout (#5934)
    The Kafka Streams system tests fail with some regularity due to a timeout starting the
    The initial start is quite quick, but many of our tests involve stopping and restarting
nodes with data already loaded, and also while processing is ongoing.
    Under these conditions, it seems to be normal for the broker to take about 25 seconds
to start, which makes the 30 second timeout pretty close for comfort.
    I have seen many test failures in which the broker successfully started within a couple
of seconds after the tests timed out and already initiated the failure/shut-down sequence.
    Reviewers: Guozhang Wang <wangguoz@gmail.com>
 tests/kafkatest/services/kafka/kafka.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tests/kafkatest/services/kafka/kafka.py b/tests/kafkatest/services/kafka/kafka.py
index c3cc9f7..75ec993 100644
--- a/tests/kafkatest/services/kafka/kafka.py
+++ b/tests/kafkatest/services/kafka/kafka.py
@@ -271,7 +271,7 @@ class KafkaService(KafkaPathResolverMixin, JmxMixin, Service):
         with node.account.monitor_log(KafkaService.STDOUT_STDERR_CAPTURE) as monitor:
             # Kafka 1.0.0 and higher don't have a space between "Kafka" and "Server"
-            monitor.wait_until("Kafka\s*Server.*started", timeout_sec=30, backoff_sec=.25,
err_msg="Kafka server didn't finish startup")
+            monitor.wait_until("Kafka\s*Server.*started", timeout_sec=60, backoff_sec=.25,
err_msg="Kafka server didn't finish startup")
         # Credentials for inter-broker communication are created before starting Kafka.
         # Client credentials are created after starting Kafka so that both loading of

View raw message