mjsax commented on a change in pull request #9688:
URL: https://github.com/apache/kafka/pull/9688#discussion_r535948890
##########
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##########
@@ -152,27 +147,6 @@
private final AtomicInteger commitCounterClient2 = new AtomicInteger(-1);
private final AtomicInteger commitRequested = new AtomicInteger(0);
- // Note: this pattern only works when we just have a single instance
running with a single thread
- // If we want to extend the test or reuse this CommitPunctuator we should
tighten it up
- private final AtomicBoolean requestCommit = new AtomicBoolean(false);
- private static class CommitPunctuator implements Punctuator {
Review comment:
This punctuator was an attempt to stabilize the test, but without
success. Removing it as this should be a proper fix now.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
