[FLINK-3178] Make Closing Behavior of Window Operators Configurable

• Type: Improvement
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.0.0
• Fix Version/s: 1.0.0
• Component/s: API / DataStream
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 16/Dec/15 10:47
• Updated: 28/Feb/19 11:14
• Resolved: 28/Jan/16 15:47

Description

Right now, all window operators emit (incomplete) in-flight windows when they are closing down. This happens for two reasons:

1. sources emit a final Long.MAX_VALUE watermark to flush out windows when they close.
2. window operators emit in-flight windows in their close() method

For some users this might not be the desired behavior so we should either change it or make it configurable.

Issue Links

• mentioned in: Page Loading...