Sergii Mikhtoniuk created FLINK-18054:
-----------------------------------------
Summary: Environment should provide API to resume from savepoint
Key: FLINK-18054
URL:
https://issues.apache.org/jira/browse/FLINK-18054 Project: Flink
Issue Type: Improvement
Components: Test Infrastructure
Affects Versions: 1.10.1
Reporter: Sergii Mikhtoniuk
Flink's savepoint API lacks symmetry.
While you can stop the job with savepoint as:
{code}
job.stopWithSavepoint(advanceToEndOfTime, checkpointDir)
{code}
... 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}}.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)