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 from guozhangwang/KMinor-fix-eos-test
@@ -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):
