Versions Compared

Key

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

...

Add state.savepoints.dir configuration key to specify the default savepoint directory and deprecate current configuration keys (see below).

Furthermore, there is the option to specify the directory ad-hoc per savepoint (via CheckpointConfig or the CLI, see below). This ad-hoc value has precedence over the default value. If no savepoint path is configured , fail (no default and no ad-hoc), the savepoint will fail.

Default Directory

Configured?

XX
Ad-hoc Directory
Configured?
X
Trigger Savepoint
Operation 
Uses ad-hoc pathUses default pathSavepoint fails

Extend CheckpointConfig

Code Block
// Stores completed checkpoints as savepoints
@PublicEvolving
void enableSavepoints();


@PublicEvolving
void enableSavepoints(String savepointPath);


@PublicEvolving
void disableSavepoints();

// Enables periodic savepoints
@PublicEvolving
void enablePeriodicSavepoints(long savepointInterval):


@PublicEvolving
void enablePeriodicSavepoints(long savepointInterval, String savepointPath):


@PublicEvolving
void disablePeriodicSavepoints();

...