THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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? | X | X | – |
Ad-hoc Directory Configured? | X | – | – |
Trigger Savepoint Operation | Uses ad-hoc path | Uses default path | Savepoint 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(); |
...