[ https://issues.apache.org/jira/browse/FLINK-16223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17042150#comment-17042150 ]
Seth Wiesman commented on FLINK-16223: -------------------------------------- I did a clean install of master and ran the tests 100 times in a loop without failure, I'm going to assume that I had a something go wrong with my local maven cache. I will close this ticket. > 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 > Priority: Major > > 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)