[FLINK-25471] wrong result if table transfrom to DataStream then keyby sum in Batch Mode

• Type: Bug
• Status: Open
• Priority: Critical
• Resolution: Unresolved
• Affects Version/s: 1.14.2
• Component/s: Table SQL / API, Table SQL / Runtime
• Labels: pull-request-available stale-assigned

Environment

mac book pro m1 

jdk 8 

scala 2.11

flink 1.14.2

idea 2020

• Assignee: Yao Zhang
• Reporter: zhangzh
• Created: 29/Dec/21 05:15
• Updated: 19/Feb/22 10:37

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 column "word"

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 parallelism ,the result is different.

 

the source file  and pom is in attach.

 is  a bug?

pelease help me!!!

 

 

 

 

 

 

 

 

 

Issue Links

• relates to: FLINK-25683 wrong result if table transfrom to DataStream then window process in batch mode
• links to: GitHub Pull Request #18308