[kafka] branch trunk updated: MINOR: fix flaky Streams EOS system test (#4728)

[mj...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

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

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

    MINOR: fix flaky Streams EOS system test (#4728)
    
    Reviewer: Guozhang Wang <gu...@confluent.io>, Bill Bejeck <bi...@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.