flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stephan Ewen (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2097) Add support for JobSessions
Date Wed, 27 May 2015 10:09:17 GMT
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)

Mime
View raw message