文章目录
1.概述
Flink SQL checkpoint越来越大咋么办，从2个G，现在4个G了，增量同步的，窗口是1小时，watermark是6小时，按道理来说，数据量不应该越来越大啊？
在窗口内执行了count(distinct )这些操作。设置了状态的ttl。后端状态存储用的rocksdb。
状态如下
设置了增量的检查点
代码设置不一定有效，需要看实际设置成功了没。这里有才说明你设置成功了
本文转载自: https://blog.csdn.net/qq_21383435/article/details/125417018
版权归原作者 九师兄 所有， 如有侵权，请联系我们删除。
版权归原作者 九师兄 所有， 如有侵权，请联系我们删除。