Hi @TisonKun , I am not sure if it fails the execution too eagerly? I think the too problem that many RPC requests and block JM can be resolved by add a single-thread thread pool so that only one request would be issued at the same time. What do you think?
[ Full content available at: https://github.com/apache/flink/pull/6680 ] This message was relayed via gitbox.apache.org for [email protected]
