[FLINK-3439] Remove final Long.MAX_VALUE Watermark in StreamSource

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.0.0
• Component/s: API / DataStream
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 18/Feb/16 10:11
• Updated: 28/Feb/19 11:15
• Resolved: 22/Feb/16 13:58

Description

I think this was an oversight. At one point we decided to not emit in-flight windows when closing the topology or sources.