flink的回撤流写入clickhouse怎么处理幂等性？

在 flink 中 full join之后的回撤流会出现重复数据 , clickhouse的replacingMergeTree 虽然能去重，但是会有延时，手动optimize又太重。怎么处理幂等性问题？