Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-35549 FLIP-461: Synchronize rescaling with checkpoint creation to minimize reprocessing for the AdaptiveScheduler
  3. FLINK-35552

Move CheckpointStatsTracker out of ExecutionGraph into Scheduler

    XMLWordPrintableJSON

Details

    Description

      The scheduler needs to know about the CheckpointStatsTracker to allow listening to checkpoint failures and completion.

      Attachments

        Issue Links

          Testing discovered

          Bug - A problem which impairs or prevents the functions of the product. FLINK-35722 CoordinatorEventsToStreamOperatorRecipientExactlyOnceITCase.testCheckpoint fails because of missed operator event

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

          Web Link GitHub Pull Request #24911

          Activity

            People

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

              Dates

                Created:
                Updated:
                Resolved: