Details
-
Improvement
-
Status: Reopened
-
Not a Priority
-
Resolution: Unresolved
-
1.10.1
-
None
-
None
Description
Flink's savepoint API lacks symmetry.
While you can stop the job with savepoint as:
job.stopWithSavepoint(advanceToEndOfTime, checkpointDir)
... there is no API to resume from one.
This make it very hard to test stop-resume functionality as it forces you to run a proper cluster and use CLI.
Workaround:
To use savepoints in my "unit" tests I'm resorting to subclassing local environment and calling streamGraphGenerator.setSavepointRestoreSettings.