[jira] [Created] (FLINK-16223) Flat aggregate misuses key group ranges

[Shang Yuanchun (Jira)]

Seth Wiesman created FLINK-16223:
------------------------------------

             Summary: Flat aggregate misuses key group ranges
                 Key: FLINK-16223
                 URL: https://issues.apache.org/jira/browse/FLINK-16223
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Planner
    Affects Versions: 1.10.0, 1.11.0
            Reporter: Seth Wiesman


The implementation of flat aggregate appears to misuse key group ranges. When we add a check in AbstractStreamOperator that the current key belongs to the key group assigned to that subtask tests in TableAggregateITCase begin to fail.

This patch can be used to reproduce the issue[1].

https://github.com/sjwiesman/flink/tree/keygrouprangecheck

cc [~jincheng] [~hequn8128]



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