kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch 1.1 updated: MINOR: fix flaky Streams EOS system test (#4728)
Date Sun, 18 Mar 2018 01:03:40 GMT
This is an automated email from the ASF dual-hosted git repository.

mjsax 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 e726593  MINOR: fix flaky Streams EOS system test (#4728)
e726593 is described below

commit e7265933fe658fb4e679caaec40df72baed4f452
Author: Matthias J. Sax <mjsax@apache.org>
AuthorDate: Sat Mar 17 18:02:20 2018 -0700

    MINOR: fix flaky Streams EOS system test (#4728)
    
    Reviewer: Guozhang Wang <guozhang@confluent.io>, Bill Bejeck <bill@confluent.io>
---
 tests/kafkatest/tests/streams/streams_eos_test.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tests/kafkatest/tests/streams/streams_eos_test.py b/tests/kafkatest/tests/streams/streams_eos_test.py
index d6ac600..7e5cc26 100644
--- a/tests/kafkatest/tests/streams/streams_eos_test.py
+++ b/tests/kafkatest/tests/streams/streams_eos_test.py
@@ -159,7 +159,7 @@ class StreamsEosTest(KafkaTest):
 
     def wait_for_startup(self, monitor, processor):
         self.wait_for(monitor, processor, "StateChange: REBALANCING -> RUNNING")
-        self.wait_for(monitor, processor, "processed 500 records from topic=data")
+        self.wait_for(monitor, processor, "processed 500 records from topic")
 
     def wait_for(self, monitor, processor, output):
         monitor.wait_until(output,

-- 
To stop receiving notification emails like this one, please contact
mjsax@apache.org.

Mime
View raw message