flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Maximilian Michels (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2250) Backtracking of intermediate results
Date Fri, 19 Jun 2015 12:32:00 GMT
Maximilian Michels created FLINK-2250:

             Summary: Backtracking of intermediate results
                 Key: FLINK-2250
                 URL: https://issues.apache.org/jira/browse/FLINK-2250
             Project: Flink
          Issue Type: New Feature
          Components: Distributed Runtime, Java API, Scala API
            Reporter: Maximilian Michels
            Assignee: Maximilian Michels

With intermediate results available in the distributed runtime as of FLINK-986, we could now
incrementally resume failed jobs if we cached the results FLINK-1404. Moreover, Flink users
could build incremental Flink jobs using count/collect/print and, ultimately, also continue
from old job results in an interactive shell environment like the scala-shell.

The following tasks need to be completed for that to happen:

- Cache the results
- Keep the ExecutionGraph in the JobManager
- Change the scheduling mechanism to track back the results from the sinks
- Implement a session management to eventually discard old results and ExecutionGraphs from
the TaskManagers/JobManager 

This message was sent by Atlassian JIRA

View raw message