You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Stephan Ewen (JIRA)" <ji...@apache.org> on 2015/05/27 12:09:17 UTC

[jira] [Created] (FLINK-2097) Add support for JobSessions

Stephan Ewen created FLINK-2097:
-----------------------------------

             Summary: Add support for JobSessions
                 Key: FLINK-2097
                 URL: https://issues.apache.org/jira/browse/FLINK-2097
             Project: Flink
          Issue Type: New Feature
          Components: JobManager
    Affects Versions: 0.9
            Reporter: Stephan Ewen
            Assignee: Maximilian Michels
             Fix For: 0.9


Sessions make sure that the JobManager does not immediately discard a JobGraph after execution, but keeps it around for further operations to be attached to the graph. By keeping the JobGraph around, the cached streams (intermediate data) are also kept,

That is the way of realizing interactive sessions on top of a streaming dataflow abstraction.

ExecutionGraphs should be kept as long as
- no timeout occurred or
- the session has not been explicitly ended




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)