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

BatchGroupedReduceOperator does not emit results for singleton inputs

    XMLWordPrintableJSON

    Details

      Description

      This was reported on the ML: https://lists.apache.org/thread.html/rf24ff56408d3f07a02a3726336229a5919e62c4179c9eb8361a5b76b%40%3Cuser.flink.apache.org%3E.

      The problem is that the logic for setting up the "final" timer does not kick in when there is only on input.

      I'll cut a PR for that and also add tests for the operator.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                aljoscha Aljoscha Krettek
                Reporter:
                aljoscha Aljoscha Krettek
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: