[
https://issues.apache.org/jira/browse/FLINK-18835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17173004#comment-17173004
]
YHF edited comment on FLINK-18835 at 8/7/20, 9:28 AM:
------------------------------------------------------
[~jark] how can I get the final result? I found duplicate data in sink method.
I print the source and grouped data and I found sometimes there is no group
data in the result changelog with using a window on the stream.
was (Author: linshi2020):
[~jark] how can I get the final result? I found duplicate data in sink method.
> sql using group by, duplicated group fileld appears
> ---------------------------------------------------
>
> Key: FLINK-18835
> URL: https://issues.apache.org/jira/browse/FLINK-18835
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Affects Versions: 1.11.1
> Reporter: YHF
> Priority: Critical
> Attachments: SumAnalysis.java
>
>
> datasource is kafka,then create a temporary view, group by (fieldA,fieldB)
> using sql,
> then transform the result table to datastream using toRetractStream, then
> print the result,
> I find duplicated (fieldA,fieldB)
> see attachment for code
> group by(scanType,scanSite,cmtInf),but result is below
> (true,Otm\{, scanType=97, scanSite=14, cmtInf=24,jp=1.000000000000000000,
> db=0E-18, dbjp=1.000000000000000000, pjWei=27.070000000000000000,
> dbWei=0E-18, mintime=2020-07-29 11:33:57.679, maxtime=2020-07-29
> 11:33:57.679})
> 3> (true,Otm\{, scanType=97, scanSite=14, cmtInf=24,jp=1.000000000000000000,
> db=0E-18, dbjp=1.000000000000000000, pjWei=27.070000000000000000,
> dbWei=0E-18, mintime=2020-07-29 11:33:57.679, maxtime=2020-07-29
> 11:33:57.679})
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
