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)

Reply via email to