Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-2286

Window ParallelMerge sometimes swallows elements of the last window

    XMLWordPrintableJSON

    Details

    • 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
    • Labels:
      None

      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.

        Attachments

          Activity

            People

            • Assignee:
              gaborhermann Gábor Hermann
              Reporter:
              mbalassi Márton Balassi
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: