[jira] [Created] (FLINK-18054) Environment should provide API to resume from savepoint

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-18054) Environment should provide API to resume from savepoint

Shang Yuanchun (Jira)
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)