[ 
https://issues.apache.org/jira/browse/FLINK-31959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Rui Fan updated FLINK-31959:
----------------------------
    Description: 
FLINK-18851 added the checkpoint type in web UI to distinguish aligned 
checkpoint, unaligned checkpoint, savepoint and savepoint on cancel in {*}Flink 
1.12{*}.

It distinguishes between UC and AC based on whether UC is enabled or 
disabled.[1]

However, FLINK-19680, FLINK-19681 and FLINK-19682 introduced the 
alignment-timeout in {*}Flink 1.13{*}, and it has been changed to 
{{aligned-checkpoint-timeout.}}
{code:java}
When activated, each checkpoint will still begin as an aligned checkpoint, but 
when the global checkpoint duration exceeds the aligned-checkpoint-timeout, if 
the aligned checkpoint has not completed, then the checkpoint will proceed as 
an unaligned checkpoint.{code}
If UC and AC-timeout is enabled and the checkpoint is completed as aligned 
checkpoint. It should show the aligned checkpoint instead of unaligned 
checkpoint.

 

[1] 
[https://github.com/apache/flink/blob/a3368635e3d06f764d144f8c8e2e06e499e79665/flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/detail/job-checkpoints-detail.component.ts#L118]

 

  was:
FLINK-18851 added the checkpoint type in web UI to distinguish aligned 
checkpoint, unaligned checkpoint, savepoint and savepoint on cancel in {*}Flink 
1.12{*}.

It distinguishes between UC and AC based on whether UC is enabled or 
disabled.[1]

However, FLINK-19680, FLINK-19681 and FLINK-19682 introduced the 
alignment-timeout in {*}Flink 1.13{*}, and it has been changed to 
{{aligned-checkpoint-timeout.}}
{code:java}
When activated, each checkpoint will still begin as an aligned checkpoint, but 
when the global checkpoint duration exceeds the aligned-checkpoint-timeout, if 
the aligned checkpoint has not completed, then the checkpoint will proceed as 
an unaligned checkpoint.{code}
If UC and AC-timeout is enabled and the checkpoint is completed as aligned 
checkpoint. It should show the unaligned checkpoint instead of aligned 
checkpoint.

 

[1] 
https://github.com/apache/flink/blob/a3368635e3d06f764d144f8c8e2e06e499e79665/flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/detail/job-checkpoints-detail.component.ts#L118

 


> Correct the unaligned checkpoint type at checkpoint level
> ---------------------------------------------------------
>
>                 Key: FLINK-31959
>                 URL: https://issues.apache.org/jira/browse/FLINK-31959
>             Project: Flink
>          Issue Type: Bug
>          Components: Runtime / Checkpointing
>    Affects Versions: 1.17.0, 1.16.1, 1.18.0
>            Reporter: Rui Fan
>            Assignee: Rui Fan
>            Priority: Major
>
> FLINK-18851 added the checkpoint type in web UI to distinguish aligned 
> checkpoint, unaligned checkpoint, savepoint and savepoint on cancel in 
> {*}Flink 1.12{*}.
> It distinguishes between UC and AC based on whether UC is enabled or 
> disabled.[1]
> However, FLINK-19680, FLINK-19681 and FLINK-19682 introduced the 
> alignment-timeout in {*}Flink 1.13{*}, and it has been changed to 
> {{aligned-checkpoint-timeout.}}
> {code:java}
> When activated, each checkpoint will still begin as an aligned checkpoint, 
> but when the global checkpoint duration exceeds the 
> aligned-checkpoint-timeout, if the aligned checkpoint has not completed, then 
> the checkpoint will proceed as an unaligned checkpoint.{code}
> If UC and AC-timeout is enabled and the checkpoint is completed as aligned 
> checkpoint. It should show the aligned checkpoint instead of unaligned 
> checkpoint.
>  
> [1] 
> [https://github.com/apache/flink/blob/a3368635e3d06f764d144f8c8e2e06e499e79665/flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/detail/job-checkpoints-detail.component.ts#L118]
>  



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

Reply via email to