Re: Flink sql retract to append

2024-04-30 文章 Zijun Zhao 
以处理时间为升序，处理结果肯定不会出现回撤的，因为往后的时间不会比当前时间小了，你可以在试试这个去重

On Tue, Apr 30, 2024 at 3:35 PM 焦童  wrote:

> 谢谢你的建议  但是top-1也会产生回撤信息
>
> > 2024年4月30日 15:27，ha.fen...@aisino.com 写道：
> >
> > 可以参考这个
> >
> https://nightlies.apache.org/flink/flink-docs-release-1.19/zh/docs/dev/table/sql/queries/deduplication/
> > 1.11版本不知道是不是支持
> >
> > From: 焦童
> > Date: 2024-04-30 11:25
> > To: user-zh
> > Subject: Flink sql retract to append
> > Hello ,
> > 我使用Flink 1.11 版本 sql  进行数据去重（通过 group by
> 形式）但是这会产生回撤流，下游存储不支持回撤流信息仅支持append，在DataStream
> 中我可以通过状态进行去重，但是在sql中如何做到去重且不产生回撤流呢。谢谢各位
>
>

Re: Flink sql retract to append

2024-04-30 文章 焦童 
谢谢你的建议  但是top-1也会产生回撤信息  

> 2024年4月30日 15:27，ha.fen...@aisino.com 写道：
> 
> 可以参考这个
> https://nightlies.apache.org/flink/flink-docs-release-1.19/zh/docs/dev/table/sql/queries/deduplication/
> 1.11版本不知道是不是支持
> 
> From: 焦童
> Date: 2024-04-30 11:25
> To: user-zh
> Subject: Flink sql retract to append
> Hello ,
> 我使用Flink 1.11 版本 sql  进行数据去重（通过 group by 
> 形式）但是这会产生回撤流，下游存储不支持回撤流信息仅支持append，在DataStream 
> 中我可以通过状态进行去重，但是在sql中如何做到去重且不产生回撤流呢。谢谢各位

Flink sql retract to append

2024-04-29 文章 焦童 
Hello ,
 我使用Flink 1.11 版本 sql  进行数据去重（通过 group by 
形式）但是这会产生回撤流，下游存储不支持回撤流信息仅支持append，在DataStream 
中我可以通过状态进行去重，但是在sql中如何做到去重且不产生回撤流呢。谢谢各位