Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-2491 Checkpointing only works if all operators/tasks are still running
  3. FLINK-21246

Decline Checkpoint if some tasks finished before get triggered

    XMLWordPrintableJSON

    Details

      Description

      When considering checkpoint while tasks get to finished, CheckpointCoordinator computes the tasks to trigger based on the current finish status, then during trigger, some more tasks might finished. In this case, CheckpointCoordinator would abort this checkpoint.

      This is an replacement option to FLINK-21081

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                gaoyunhaii Yun Gao
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated: