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

Checkpoints can complete after CheckpointFailureManager fails job

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Closed
    • Critical
    • Resolution: Fixed
    • 1.9.0, 1.10.0
    • 1.11.0
    • Runtime / Checkpointing
    • None

    Description

      I think that we introduced with FLINK-12364 an inconsistency wrt to job termination a checkpointing. In FLINK-9900 it was discovered that checkpoints can complete even after the CheckpointFailureManager decided to fail a job. I think the expected behaviour should be that we fail all pending checkpoints once the CheckpointFailureManager decides to fail the job.

      Attachments

        Issue Links

          causes

          Bug - A problem which impairs or prevents the functions of the product. FLINK-9900 Fix unstable test ZooKeeperHighAvailabilityITCase#testRestoreBehaviourWithFaultyStateHandles

          • Critical - Crashes, loss of data, severe memory leak.
          • Closed
          is caused by

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-13698 Rework threading model of CheckpointCoordinator

          • Not a Priority -
          • Reopened

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-16945 Execute CheckpointFailureManager.FailJobCallback directly in main thread executor

          • Major - Major loss of function.
          • Closed
          is fixed by

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-16945 Execute CheckpointFailureManager.FailJobCallback directly in main thread executor

          • Major - Major loss of function.
          • Closed
          is related to

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-5960 Make CheckpointCoordinator less blocking

          • Major - Major loss of function.
          • Closed
          relates to

          Bug - A problem which impairs or prevents the functions of the product. FLINK-13527 Instable KafkaProducerExactlyOnceITCase due to CheckpointFailureManager

          • Critical - Crashes, loss of data, severe memory leak.
          • Closed

          Activity

            People

              SleePy Biao Liu
              trohrmann Till Rohrmann
              Votes:
              0 Vote for this issue
              Watchers:
              10 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: