tillrohrmann opened a new pull request #14553: URL: https://github.com/apache/flink/pull/14553
In order to support reusing checkpoints across different `ExecutionGraph` instances, this PR decouples the checkpoint services `CompletedCheckpointStore` and `CheckpointIDCounter` from the lifetime of the `CheckpointCoordinator`. Concretely, this means that these services won't be shut down by the `CheckpointCoordinator` but by an instance which can live longer than the `CheckpointCoordinator`. The current owner of the checkpoint services is the `SchedulerBase`. * 7e2af0e Factor out CompletedCheckpointStore and CheckpointIDCounter creation in ExecutionGraphBuilder.buildGraph * ab4b146 Move CheckpointIDCounter creation out of ExecutionGraphBuilder * c5b6e2c Move CompletedCheckpointStore creation out of ExecutionGraphBuilder.buildGraph * 040cffc Remove CheckpointRecoveryFactory from ExecutionGraphBuilder.buildGraph * fa3309b Move checkpoint service shut down out of CheckpointCoordinator ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
