[jira] [Created] (FLINK-2286) Window ParallelMerge sometimes swallows elements of the last window

[Shang Yuanchun (Jira)]

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)