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

The unaligned checkpoint type is wrong at subtask level

    XMLWordPrintableJSON

Details

    Description

      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).

       

       

      Attachments

        Issue Links

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: