Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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.checkpointing.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 execution.recovery.from-local is added to control the behavior of recovery from local

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.local-copy is set as true

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.*


...