Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-11813 Standby per job mode Dispatchers don't know job's JobSchedulingStatus
  3. FLINK-25432

Introduce common interfaces for cleaning up local and global job data

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 1.15.0
    • 1.15.0
    • None

    Description

      We want to combine the job-specific cleanup of the different resources and provide a common ResourceCleaner taking care of the actual cleanup of all resources.

      This needs to be integrated into the Dispatcher.

      Attachments

        Issue Links

          causes

          Sub-task - The sub-task of the issue FLINK-26117 JobManagerMetricGroup needs to implement GloballyCleanableResource as well

          • Major - Major loss of function.
          • Resolved

          Bug - A problem which impairs or prevents the functions of the product. FLINK-26606 CompletedCheckpoints that failed to be discarded are not stored in the CompletedCheckpointStore

          • Major - Major loss of function.
          • Open

          Bug - A problem which impairs or prevents the functions of the product. FLINK-26284 The ZooKeeperStateHandleStore cleans the metadata before cleaning the StateHandle

          • Blocker - Blocks development and/or testing work, production could not run
          • Resolved

          Bug - A problem which impairs or prevents the functions of the product. FLINK-26286 The KubernetesStateHandleStore cleans the metadata before cleaning the StateHandle

          • Blocker - Blocks development and/or testing work, production could not run
          • Resolved

          Technical Debt - FLINK-26175 Make local cleanup being called in global cleanup situations

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

          Bug - A problem which impairs or prevents the functions of the product. FLINK-24038 DispatcherResourceManagerComponent fails to deregister application if no leading ResourceManager

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

          Technical Debt - FLINK-25806 Remove legacy high availability services

          • Blocker - Blocks development and/or testing work, production could not run
          • Closed
          Testing discovered

          Bug - A problem which impairs or prevents the functions of the product. FLINK-25902 NullPointerException in RescalingITCase.testSavepointRescalingOutKeyedState

          • Major - Major loss of function.
          • Closed

          Bug - A problem which impairs or prevents the functions of the product. FLINK-25903 Heartbeat timeout in BoundedSourceITCase.test[complex graph]

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

          Web Link GitHub Pull Request #18536

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: