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

发布于 15 天前 作者 windyzj 164 次浏览 来自 问答

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

回到顶部