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

Yun Gao commented on FLINK-23430:
---------------------------------

Fix on master via e8ecf45efbcbc005129492d9f289bf7b277e89ad

> Take snapshots for operator coordinators which all corresponding 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: Yun Gao
>            Priority: Major
>              Labels: pull-request-available
>             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