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

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

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

Timo Walther reassigned FLINK-25471:
------------------------------------

    Assignee: Yao Zhang

> 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
>            Assignee: Yao Zhang
>            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)