[FLINK-2097] Add support for JobSessions

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Implemented
• Affects Version/s: 0.9
• Fix Version/s: 0.10.0
• Component/s: Runtime / Coordination
• Assignee: Maximilian Michels
• Reporter: Stephan Ewen
• Created: 27/May/15 10:08
• Updated: 28/Feb/19 14:01
• Resolved: 22/Sep/15 19:59

Description

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

Issue Links

• is duplicated by: FLINK-2251 Implement job session management
• relates to: FLINK-1730 Add a FlinkTools.persist style method to the Data Set.