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)