Re: Flink sql retract to append

[焦童]

谢谢你的建议  但是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中如何做到去重且不产生回撤流呢。谢谢各位