You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Rui Fan (Jira)" <ji...@apache.org> on 2023/04/25 02:24:00 UTC

[jira] [Comment Edited] (FLINK-31588) The unaligned checkpoint type is wrong at subtask level

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

Rui Fan edited comment on FLINK-31588 at 4/25/23 2:23 AM:
----------------------------------------------------------

Thanks [~pnowojski] for the review and discussion.

Merged master commit: d46d8d0f6b590f185608b23fbe8b2fcbded111de

Merged 1.17-release commit : a3c00eed371f8a2c9bfe557fa07dc7bc8a04f14e

Merged 1.16-release commit : 60cadec7c1f3beb3c9eb7e45cbd7ab9d99062e48


was (Author: fanrui):
Thanks [~pnowojski] for the review and discussion.

Merged master commit: d46d8d0f6b590f185608b23fbe8b2fcbded111de

> The unaligned checkpoint type is wrong at subtask level
> -------------------------------------------------------
>
>                 Key: FLINK-31588
>                 URL: https://issues.apache.org/jira/browse/FLINK-31588
>             Project: Flink
>          Issue Type: Bug
>          Components: Runtime / Checkpointing
>    Affects Versions: 1.16.0, 1.17.0
>            Reporter: Rui Fan
>            Assignee: Rui Fan
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.18.0
>
>         Attachments: image-2023-03-23-18-45-01-535.png
>
>
> FLINK-20488 supported show checkpoint type for each subtask, and it based on received `CheckpointOptions` and it's right.
> However, FLINK-27251 supported timeout aligned to unaligned checkpoint barrier in the output buffers. It means the received `CheckpointOptions` can be converted from aligned checkpoint to unaligned checkpoint.
> So, the unaligned checkpoint type may be wrong at subtask level. For example, as shown in the figure below, Unaligned checkpoint type is false, but it is actually Unaligned checkpoint (persisted data > 0).
>  
> !image-2023-03-23-18-45-01-535.png|width=1879,height=797!
>  



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