[jira] [Created] (FLINK-21450) Add local recovery support to adaptive scheduler

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

[jira] [Created] (FLINK-21450) Add local recovery support to adaptive scheduler

Shang Yuanchun (Jira)
Robert Metzger created FLINK-21450:
--------------------------------------

             Summary: Add local recovery support to adaptive scheduler
                 Key: FLINK-21450
                 URL: https://issues.apache.org/jira/browse/FLINK-21450
             Project: Flink
          Issue Type: New Feature
          Components: Runtime / Coordination
            Reporter: Robert Metzger


local recovery means that, on a failure, we are able to re-use the state in a taskmanager, instead of loading it again from distributed storage (which means the scheduler needs to know where which state is located, and schedule tasks accordingly).

Adaptive Scheduler is currently not respecting the location of state, so failures require the re-loading of state from the distributed storage.

Adding this feature will allow us to enable the {{Local recovery and sticky scheduling end-to-end test}} for adaptive scheduler again.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)