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)
