Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/4907#discussion_r147089150
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java
---
@@ -116,6 +117,10 @@
* accessing this don't block the job manager actor and run
asynchronously. */
private final CompletedCheckpointStore completedCheckpointStore;
+ /** The root checkpoint state backend, which is responsible for
initializing the
+ * checkpoint, storing the metadata, and cleaning up the checkpoint */
+ private final StateBackend checkpointStateBackend;
--- End diff --
No, not really. Wanted to pick a name here that allows us later to possibly
have different "backends" for the data structure, meaning heap and RocksDB in
different operators. One state backend needs to be the root that defines how
metadata is checkpointed and recovered.
---
