[jira] [Created] (FLINK-14971) Move ACK and declined message handling in the same thread with triggering

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-14971) Move ACK and declined message handling in the same thread with triggering

Shang Yuanchun (Jira)
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)