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

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

    [ https://issues.apache.org/jira/browse/FLINK-25471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17468387#comment-17468387 ] 

Yao Zhang commented on FLINK-25471:
-----------------------------------

Hi [~zhangzihan] ,

I reproduced this issue with Flink 1.14.2.

I also tested with Flink 1.13.3 but both streaming and batch mode worked fine, with the expected outputs.

> wrong result if table transfrom to DataStream then keyby  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, 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: Critical
>         Attachments: TableToDataStreamBatchWordCount-1.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 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!!!
>  
>  
>  
>  
>  
>  
>  
>  
>  



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