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

Posted to issues@flink.apache.org by "Fabian Hueske (JIRA)" <ji...@apache.org> on 2017/07/20 12:31:00 UTC

[jira] [Created] (FLINK-7239) GroupWindow and OverWindow aggregates do not check correctly for updating input

Fabian Hueske created FLINK-7239:
------------------------------------

             Summary: GroupWindow and OverWindow aggregates do not check correctly for updating input
                 Key: FLINK-7239
                 URL: https://issues.apache.org/jira/browse/FLINK-7239
             Project: Flink
          Issue Type: Bug
          Components: Table API & SQL
    Affects Versions: 1.3.1, 1.4.0
            Reporter: Fabian Hueske


The streaming table operators for group-window and over-window aggregates do only support append-only input, i.e., no updates.

However, the {{DataStreamGroupWindowAggregate}} {{DataStreamOverAggregate}} RelNodes do only check that the input does not have retraction messages which is only one possible encoding of updates.

We should fix the RelNodes to check if the input is append-only using the {{UpdatingPlanChecker}} similar to {{DataStreamWindowJoin}}.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)