Page History

...

Discussion thread: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-FLIP-10-Unify-Savepoints-and-Checkpoints-tt13149.html

JIRA: 

Released: –

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

...

Allow the user to configure periodic triggering of savepoints. The behaviour should be the same as manually triggering a savepoint every X secondssimilar to the periodic checkpoints with an extra configuration value for the maximum number of retained periodic savepoints. These savepoints are not discarded automaticallyonly discarded when the queue is full.

Miscellaneous

Always Create CheckpointCoordinator

...

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


@PublicEvolving
void enableSavepoints(enablePersistentCheckpoints(String savepointPathpath);


@PublicEvolving
void disableSavepointsdisablePersistentCheckpoints();

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


@PublicEvolving
void enablePeriodicSavepoints(long savepointIntervalinterval, TimeUnit unit, String savepointPath):


@PublicEvolving
void disablePeriodicSavepoints();

...