kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch 1.1 updated: MINOR: increase the timeout for the streams broker resilience test (#5649)
Date Fri, 14 Sep 2018 17:42:51 GMT
This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/1.1 by this push:
     new a1d6bdc  MINOR: increase the timeout for the streams broker resilience test (#5649)
a1d6bdc is described below

commit a1d6bdc74276ae0ab737dc846f1447a62349a5a0
Author: John Roesler <vvcephei@users.noreply.github.com>
AuthorDate: Fri Sep 14 12:42:35 2018 -0500

    MINOR: increase the timeout for the streams broker resilience test (#5649)
    
    After observing what seems to be a transient system test failure related to recovery just
being a little slower than expected, I'm recommending to increase the timeout to the same
value we use for trunk.
    
    Reviewers: Bill Bejeck <bill@confluent.io>, Guozhang Wang <wangguoz@gmail.com>
---
 tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py b/tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py
index bd90d9f..5440c2d 100644
--- a/tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py
+++ b/tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py
@@ -72,8 +72,8 @@ class StreamsBrokerDownResilience(Test):
         consumer.start()
 
         wait_until(lambda: consumer.total_consumed() > 0,
-                   timeout_sec=60,
-                   err_msg="At %s streams did not process messages in 60 seconds " % test_state)
+                   timeout_sec=120,
+                   err_msg="At %s streams did not process messages in 120 seconds " % test_state)
 
     def setUp(self):
         self.zk.start()


Mime
View raw message