[jira] [Updated] (FLINK-25683) wrong result if table transfrom to DataStream then window process grouped to mini batch in batch mode

["zhangzh (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-25683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

zhangzh updated FLINK-25683:
----------------------------
    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)

> wrong result if table transfrom to DataStream then window process grouped to mini batch in batch mode
> -----------------------------------------------------------------------------------------------------
>
>                 Key: FLINK-25683
>                 URL: https://issues.apache.org/jira/browse/FLINK-25683
>             Project: Flink
>          Issue Type: Bug
>          Components: Table SQL / API, Table SQL / Runtime
>    Affects Versions: 1.14.2
>         Environment: mac book pro m1 
> jdk 8 
> scala 2.11
> flink 1.14.2
> idea 2020
>            Reporter: zhangzh
>            Priority: Major
>         Attachments: TableToDataStreamBatchWindowTest.scala, pom.xml
>
>
> 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)



--
This message was sent by Atlassian Jira
(v8.20.1#820001)