You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Wencong Liu (Jira)" <ji...@apache.org> on 2023/03/04 08:03:00 UTC

[jira] [Commented] (FLINK-27051) CompletedCheckpoint.DiscardObject.discard is not idempotent

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

Wencong Liu commented on FLINK-27051:
-------------------------------------

Hello [~mapohl] , I'm quite interested in the issues under this umbrella. For this issue, do you mean the CompletedCheckpoint.DiscardObject.discard should only discard related data at the first time when it's invoked in multiple times？

> CompletedCheckpoint.DiscardObject.discard is not idempotent
> -----------------------------------------------------------
>
>                 Key: FLINK-27051
>                 URL: https://issues.apache.org/jira/browse/FLINK-27051
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Coordination
>    Affects Versions: 1.15.0
>            Reporter: Matthias Pohl
>            Priority: Major
>
> `CompletedCheckpoint.DiscardObject.discard` is not implemented in an idempotent fashion because we're losing the operatorState even in the case of a failure (see [CompletedCheckpoint:328||https://github.com/apache/flink/blob/dc419b5639f68bcb0b773763f24179dd3536d713/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpoint.java#L328]. This prevents us from retrying the deletion.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)