以处理时间为升序，处理结果肯定不会出现回撤的，因为往后的时间不会比当前时间小了，你可以在试试这个去重
On Tue, Apr 30, 2024 at 3:35 PM 焦童 <asd994144...@gmail.com> 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中如何做到去重且不产生回撤流呢。谢谢各位 > >
