[ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
zhangzh updated FLINK-25471: ---------------------------- Description: 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. the source file and pom is in attach was: 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. > 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: TableToDataStreamBatchWordCount.scala, 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. > > the source file and pom is in attach > > > > > > > -- This message was sent by Atlassian Jira (v8.20.1#820001)