[FLINK-6984] Do not recover CompletedCheckpointStore on every restore

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 1.2.1, 1.3.0, 1.4.0
• Fix Version/s: 1.12.0
• Component/s: Runtime / State Backends
• Assignee: Jiayi Liao
• Reporter: Stefan Richter
• Created: 22/Jun/17 09:00
• Updated: 18/Nov/20 08:10
• Resolved: 18/Nov/20 08:10

Description

Currently, restoring the latest checkpoint always recovers the CompletedCheckpointStore in CheckpointCoordinator::restoreLatestCheckpointedState(...) by calling completedCheckpointStore.recover(sharedStateRegistry). I think this is not required on every restore, but can happen only once when the JM becomes leader, e.g. when the CheckpointCoordinator is created. This can avoid unnecessary work and simplify the logic, e.g. for populating the SharedStateRegistry, and we could probably also move the ownership for SharedStateRegistry into some AbstractCompletedCheckpontStore.

Issue Links

• is duplicated by: FLINK-19596 Do not recover CompletedCheckpointStore on each failover
• relates to: FLINK-10712 RestartPipelinedRegionStrategy does not restore state