Roman Khachatryan created FLINK-20943:
-----------------------------------------
Summary: AsyncCheckpointRunnable.cleanup() runs in the main task
thread
Key: FLINK-20943
URL: https://issues.apache.org/jira/browse/FLINK-20943
Project: Flink
Issue Type: Bug
Components: Runtime / Checkpointing
Affects Versions: 1.11.3, 1.12.0, 1.13.0
Reporter: Roman Khachatryan
Assignee: Roman Khachatryan
Fix For: 1.13.0, 1.12.2
In FLINK-8871 an RPC notification about checkpoint abortion was added.
Upon receiving it, task cancels the running state-persisting futures. It does
so through mailbox. Cancelling the futures may involve waiting for their result
(if they can't be cancelled).
This essentially makes checkpoint sync from async upon such RPC.
cc [~yunta], [~pnowojski]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
