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

Correct the unaligned checkpoint type at checkpoint level

    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

        Issue Links

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: