kafka-commits mailing list archives

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

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


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

commit cc427c23f072665fc55eaf128a5b16699460caf6
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
broker.
    
    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 8eee575..0e05147 100644
--- a/tests/kafkatest/services/kafka/kafka.py
+++ b/tests/kafkatest/services/kafka/kafka.py
@@ -253,7 +253,7 @@ class KafkaService(KafkaPathResolverMixin, JmxMixin, Service):
         with node.account.monitor_log(KafkaService.STDOUT_STDERR_CAPTURE) as monitor:
             node.account.ssh(cmd)
             # 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


Mime
View raw message