[
https://issues.apache.org/jira/browse/FLINK-20943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Khachatryan updated FLINK-20943:
--------------------------------------
Description:
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 the mailbox.
Cancelling the futures may involve waiting for their result (if they can't be
cancelled).
This essentially makes checkpoint sync from async upon receiving such RPC.
cc [~yunta], [~pnowojski]
was:
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]
> 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.12.0, 1.11.3, 1.13.0
> Reporter: Roman Khachatryan
> Assignee: Roman Khachatryan
> Priority: Major
> 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 the mailbox.
> Cancelling the futures may involve waiting for their result (if they can't be
> cancelled).
>
> This essentially makes checkpoint sync from async upon receiving such RPC.
>
> cc [~yunta], [~pnowojski]
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
