Flink has a deadlock case and can be caused by the combination of Flink's backpressure mechanism with iterations (more likely when there is heavy feedback load).
There is a proposal(FLIP-15) to resolve this issue, but it seems to be abondoned: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=66853132
I propose to add `ThrottledMapper` into `flink-examples` directory of Flink repo, to serve as a walkaround before the deadlock issue gets resolved: https://gist.github.com/nanmu42/53fe23c3f15c777291108a7f4df62b9a
I am considering to add it into https://github.com/apache/flink/tree/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/utils
I am looking for committer support.
If it is a ok, I would like to contribute.
Thanks for your attention.