[FLINK-25683] wrong result if table transfrom to DataStream then window process in batch mode

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.14.2
• Fix Version/s: 1.13.6, 1.14.4, 1.15.0
• Component/s: Table SQL / API, Table SQL / Runtime
• Labels: pull-request-available

Environment

mac book pro m1 

jdk 8 

scala 2.11

flink 1.14.2

idea 2020

• Assignee: Yao Zhang
• Reporter: zhangzh
• Created: 18/Jan/22 04:28
• Updated: 24/Jan/22 16:03
• Resolved: 24/Jan/22 08:38

Description

I have 5 line datas,
i first need to transform current data with SQL
then mix current data and historical data which is batch get from hbase
for some special reason the program must run in batch mode
i think the correct result should be like this：
(BOB,1)
(EMA,1)
(DOUG,1)
(ALICE,1)
(CENDI,1)
but the result is :
(EMA,1)

 

if i set different parallelism ,the result is different.

Issue Links

• is related to: FLINK-25471 wrong result if table transfrom to DataStream then keyby sum in Batch Mode
• links to: GitHub Pull Request #18405