Biao Liu created FLINK-14971:
--------------------------------
Summary: Move ACK and declined message handling in the same thread with triggering
Key: FLINK-14971
URL:
https://issues.apache.org/jira/browse/FLINK-14971 Project: Flink
Issue Type: Sub-task
Components: Runtime / Checkpointing
Reporter: Biao Liu
Fix For: 1.10.0
Currently the ACK and declined message handling are executed in IO thread. It should be moved into main thread eventually.
After this step, all operations could be executed in main thread. Also we don't need coordinator-wide lock anymore then.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)