Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-31959

Correct the unaligned checkpoint type at checkpoint level

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    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.

      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.

      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

       

      Attachments

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            fanrui Rui Fan
            fanrui Rui Fan
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment