You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Aljoscha Krettek (Jira)" <ji...@apache.org> on 2020/12/24 21:00:00 UTC

[jira] [Created] (FLINK-20764) BatchGroupedReduceOperator does not emit results for singleton inputs

Aljoscha Krettek created FLINK-20764:
----------------------------------------

             Summary: BatchGroupedReduceOperator does not emit results for singleton inputs
                 Key: FLINK-20764
                 URL: https://issues.apache.org/jira/browse/FLINK-20764
             Project: Flink
          Issue Type: Improvement
          Components: API / DataStream
            Reporter: Aljoscha Krettek
            Assignee: Aljoscha Krettek
             Fix For: 1.12.1


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.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)