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

CheckpointPlanCalculator should abort checkpoint if tasks is in canceling/canceled and so on

    XMLWordPrintableJSON

Details

    Description

      When refactoring the checkpoint triggering logic in  FLINK-21067, it tries to also support the FINISHED state, but it change the abort condition from == RUNNING to != (CREATED, SCHEDULED, DEPLOYING), which makes the checkpoint could not be aborted in these cases. This might happen if during trigger there is also job failover. It might cause trigger failure and make checkpoint has to wait for timeout.

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              gaoyunhaii Yun Gao
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: