Márton Balassi created FLINK-2286:
-------------------------------------
Summary: Window ParallelMerge sometimes swallows elements of the
last window
Key: FLINK-2286
URL: https://issues.apache.org/jira/browse/FLINK-2286
Project: Flink
Issue Type: Bug
Components: Streaming
Affects Versions: 0.9, 0.10
Reporter: Márton Balassi
Assignee: Márton Balassi
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.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
