[
https://issues.apache.org/jira/browse/FLINK-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu updated FLINK-14971:
-----------------------------
Description:
Currently the ACK and declined message handling are executed in IO thread. This
is the only rest part that non-IO operations are executed in IO thread. It
blocks introducing main thread executor for {{CheckpointCoordinator}}. It would
be resolved in this task.
After resolving the ACK and declined message issue, all operations could be
executed in main thread. Also we don't need coordinator-wide lock anymore then.
was:
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.
> Make all the non-IO operations in CheckpointCoordinator single-threaded
> -----------------------------------------------------------------------
>
> Key: FLINK-14971
> URL: https://issues.apache.org/jira/browse/FLINK-14971
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Checkpointing
> Reporter: Biao Liu
> Assignee: Biao Liu
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.11.0
>
> Time Spent: 10m
> Remaining Estimate: 0h
>
> Currently the ACK and declined message handling are executed in IO thread.
> This is the only rest part that non-IO operations are executed in IO thread.
> It blocks introducing main thread executor for {{CheckpointCoordinator}}. It
> would be resolved in this task.
> After resolving the ACK and declined message issue, 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)
