来一个实战案例：博主以一个日志上报重复的场景，来引出下文要介绍的 flink sql deduplication 解决方案 基于 Deduplication 的解决方案及原理解析：博主期望你了解到，deduplication 中，当 row_number order by proctime (处理时间)去重的原理就是给每一个 partition key 维护一个 value state。

SQL 不再使用 COUNT，而是改用 LIMIT 1，让数据库查询时遇到一条就返回，不要再继续查找还有多少条了。 业务代码中直接判断是否非空即可!

Contribute to waylau/distributed-system-tutorial-samples development by creating an account on GitHub.