Github user snuyanzin commented on the issue:
https://github.com/apache/flink/pull/6040
@tzulitai thank you for your review and comments
based on your comments I have a question. Could you please clarify it?
You mentioned Flink's `OneShotLatch ` and `CheckedThread ` at the same time
in some Kafka connector's tests used `AtomicReference`, `Thread` and etc. (I
used one of them as an example while writing my version of the test). Just to
be on the sage am I right that `OneShotLatch ` and `CheckedThread ` in tests
are more preferable or are there some rules/limitations/whatever?
---
