Page History

...

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 (no default and no ad-hoc), the savepoint will fail.

...

Default Directory

Configured?

...

...

Extend CheckpointConfig

// Stores completed checkpoints as savepoints
@PublicEvolving
void enablePersistentCheckpoints(String path);

@PublicEvolving
void disablePersistentCheckpoints();

// Enables periodic savepoints
@PublicEvolving
void enablePeriodicSavepoints(long interval, TimeUnit unit, String savepointPathpath):

@PublicEvolving
void disablePeriodicSavepoints();

...

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.enableSavepoints();
env.enableSavepointsenablePersistentCheckpoints(String savepointPathpath);
env.disableSavepointsdisablePersistentCheckpoints();

Add Optional Savepoint Path Argument to CLI

...

bin/flink savepoint <JobID> [<SavepointPath<Path>]

Add REST API and Logging

...