[FLINK-2286] Window ParallelMerge sometimes swallows elements of the last window

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.9, 0.10.0
• Fix Version/s: 0.9.1, 0.10.0
• Component/s: API / DataStream
• Assignee: Gábor Hermann
• Reporter: Márton Balassi
• Created: 29/Jun/15 08:50
• Updated: 28/Feb/19 11:15
• Resolved: 19/Aug/15 13:38

Description

Last windows in the stream that do not have parts at all the parallel operator instances get swallowed by the ParallelMerge.

To resolve this ParallelMerge should be an operator instead of a function, so the close method can access the collector and emit these.