Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4751
@pnowojski I am wondering whether this is really necessary. This is not
quite a busy loop after all, because the `collect()` call emits to the Kafka
Producer and goes through buffering and I/O.
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4751
But this is not supposed to be a stress test, so why make it more
computation demanding/longer to execute?
---
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/4751
I assume that the `Thread.sleep(1)` should not do much harm if the Kafka
Producer already blocks due to buffering and I/O. If it should not block, then
the `Thread.sleep(1)` will give other thre
