[ 
https://issues.apache.org/jira/browse/FLINK-23430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17392277#comment-17392277
 ] 

Dawid Wysakowicz commented on FLINK-23430:
------------------------------------------

We should also think what should happen when restoring a coordinator for a 
fully finished state. Currently, it will be restored to an initial state which 
might cause problems in combination with finished subtasks. We should consider 
not starting the coordinator in such cases or at least start with a "finished" 
state.

> Do not take snapshot for operator coordinators which all tasks finished
> -----------------------------------------------------------------------
>
>                 Key: FLINK-23430
>                 URL: https://issues.apache.org/jira/browse/FLINK-23430
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Checkpointing
>            Reporter: Dawid Wysakowicz
>            Assignee: Dawid Wysakowicz
>            Priority: Major
>             Fix For: 1.14.0
>
>
> Currently we trigger checkpoints for all operator coordinators irrespective 
> if their corresponding tasks finished or not. This leads e.g. to a 
> precondition in 
> {{org.apache.flink.runtime.checkpoint.PendingCheckpoint#fulfillFullyFinishedOperatorStates}}
>  failing



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to