...
Original (Current) option | Proposed New option | Note |
state.checkpoints.num-retained | execution.checkpointing.num-retained | |
state.checkpoint.cleaner.parallel-mode | execution.checkpointing.cleaner.parallel-mode | |
state.backend.incremental |
execution.checkpoint.mode | an enumeration option which can be 'full' (default) or 'incremental' |
state.backend.local-recovery | execution.checkpointing.local-copy.enabled | Whether to do checkpoint on local disk, another option |
taskmanager.state.local.root-dirs | execution.checkpointing.local-copy.dir | |
state.savepoints.dir | execution.checkpointing.savepoint.dir | |
state.checkpoints.dir state.checkpoint-storage | execution.checkpointing.dir | One URI is enough for specifying the checkpoint directory and storage. 'jobmanager' and 'jm://' are special URI for job manager based storage. |
state.storage.fs.memory-threshold | execution.checkpointing.data-inline-threshold | |
state.storage.fs.write-buffer-size | execution.checkpointing.write-buffer |
All those options will be moved into `ExecutionCheckpointingOptions``CheckpointingOptions`.
Recovery
Original (Current) option | Proposed New option | Note |
execution.savepoint.path | execution.recovery.path | |
execution.savepoint.ignore-unclaimed-state | execution.recovery.ignore-unclaimed-state | |
execution.savepoint-restore-mode | execution.recovery.claim-mode | |
state.backend.local-recovery | execution.recovery.from-local | Specifies whether to recover from local, the local files are created while the |
execution.checkpointing.approximate-local-recovery | execution.recovery.approximate-local-recovery | |
execution.checkpointing.recover-without-channel-state.checkpoint-id | execution.recovery.without-channel-state.checkpoint-id |
All those options will be moved into a newly introduced class `ExecutionRecoveryOptions``RecoveryOptions` in flink-core.
State
Original (Current) option | Proposed New option | Note |
state.backend.changelog.* | state.changelog.* | |
dstl.* | state.changelog.dstl.* | |
state.backend.latency-track.* | state.latency-track.* |
...