flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Márton Balassi (JIRA) <j...@apache.org>
Subject [jira] [Created] (FLINK-2286) Window ParallelMerge sometimes swallows elements of the last window
Date Mon, 29 Jun 2015 08:50:04 GMT
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)

Mime
View raw message