frankvicky commented on code in PR #16350:
URL: https://github.com/apache/kafka/pull/16350#discussion_r1640916109
##########
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/SynchronizationTest.java:
##########
@@ -113,19 +111,14 @@ public synchronized void clear() {
public synchronized void set(Predicate<T> predicate) {
clear();
this.predicate = predicate;
- // As soon as the barrier is tripped, the barrier will be reset
for the next round.
barrier = new CyclicBarrier(2);
}
- /**
Review Comment:
by mistake 😢
will roll it back.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
