From 7d6f6f7320f2058d1108224eefe615e333955721 Mon Sep 17 00:00:00 2001 From: Guozhang Wang Date: Wed, 20 Dec 2017 18:44:36 -0800 Subject: [PATCH] MINOR: Fix race condition in Streams EOS system test We should start the process only within the `with` block, otherwise the bytes parameter would cause a race condition that result in false alarms of system test failures. Author: Guozhang Wang Reviewers: Ewen Cheslack-Postava Closes #4348 from guozhangwang/KMinor-fix-eos-test --- 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 0863e250f82..623d0363d21 100644 --- a/tests/kafkatest/tests/streams/streams_eos_test.py +++ b/tests/kafkatest/tests/streams/streams_eos_test.py @@ -118,8 +118,8 @@ class StreamsEosTest(KafkaTest): verifier.node.account.ssh("grep ALL-RECORDS-DELIVERED %s" % verifier.STDOUT_FILE, allow_fail=False) def add_streams(self, processor): - processor.start() with processor.node.account.monitor_log(processor.STDOUT_FILE) as monitor: + processor.start() self.wait_for_startup(monitor, processor) def add_streams2(self, running_processor, processor_to_be_started):