[jira] [Updated] (FLINK-2097) Add support for JobSessions
[ https://issues.apache.org/jira/browse/FLINK-2097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ufuk Celebi updated FLINK-2097: --- Fix Version/s: (was: 0.9) 0.10 > Add support for JobSessions > --- > > Key: FLINK-2097 > URL: https://issues.apache.org/jira/browse/FLINK-2097 > Project: Flink > Issue Type: Sub-task > Components: JobManager >Affects Versions: 0.9 >Reporter: Stephan Ewen >Assignee: Maximilian Michels > Fix For: 0.10 > > > 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)
[jira] [Updated] (FLINK-2097) Add support for JobSessions
[ https://issues.apache.org/jira/browse/FLINK-2097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maximilian Michels updated FLINK-2097: -- Issue Type: Sub-task (was: New Feature) Parent: FLINK-2250 > Add support for JobSessions > --- > > Key: FLINK-2097 > URL: https://issues.apache.org/jira/browse/FLINK-2097 > Project: Flink > Issue Type: Sub-task > 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)