[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
zhangzh updated FLINK-25471: ---------------------------- Attachment: pom.xml > wrong result if table toDataStream then keyey by sum in Batch Mode > ------------------------------------------------------------------ > > Key: FLINK-25471 > URL: https://issues.apache.org/jira/browse/FLINK-25471 > Project: Flink > Issue Type: Bug > Components: Table SQL / API > Affects Versions: 1.14.2 > Reporter: zhangzh > Priority: Critical > Attachments: pom.xml > > > I have a dataStream with 6 lines datas like this: > Row.of("Alice"), > Row.of("alice"), > Row.of("Bob"), > Row.of("lily"), > Row.of("lily"), > Row.of("lily") > then make it to table with one colums "wrod" > then sql transform : select upper(word) from tmp_table > then change to dataStream > then keyby sum. > > in batch mode: > I think correct result is: > > (BOB,1) > > (ALICE,2) > > (LILY,3) > > but the result is : > > (BOB,1) > if i set different parallelish ,the result is different. > > > > > > > -- This message was sent by Atlassian Jira (v8.20.1#820001)