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)

Reply via email to