Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-26606 CompletedCheckpoints that failed to be discarded are not stored in the CompletedCheckpointStore
  3. FLINK-27052

FsCompletedCheckpointStorageLocation.disposeStorageLocation doesn't expose errors properly (not processing the return value)

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 1.15.0
    • None
    • Runtime / Coordination
    • None

    Description

      CompletedCheckpointStorageLocation.disposeStorageLocation is called in CompletedCheckpoint.DiscardObject.discard. The implementing class FsCompletedCheckpointStorageLocation doesn't implement this method in an idempotent way because it doesn't process the return value of the delete method. Hence, we might lose error cases.

      Attachments

        Activity

          People

            Unassigned Unassigned
            mapohl Matthias Pohl
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: