Flink窗口状态清除疑问

Mon, 24 Jul 2023 20:22:10 -0700 

相关配置：
Flink:1.16

| Checkpointing Mode | Exactly Once |
| Checkpoint Storage | FileSystemCheckpointStorage |
| State Backend | EmbeddedRocksDBStateBackend |
| Interval | 8m 0s |


我有一个程序，主要是用来统计一些热门商品之类的数据
具体代码如下：
.keyBy(data -> data.getShopId() + data.getYh_productid())
.window(TumblingEventTimeWindows.of(Time.minutes(30)))
.sum("count").name("clickCount");


按照官方文档的说法，状态在窗口触发后应该就会清除。但是我在webui上以及grafana监控上看到的checkpoint大小一直在增长。
webui:https://pic.imgdb.cn/item/64bf3efa1ddac507cc6484d5.jpg
grafana:https://pic.imgdb.cn/item/64bf3fb71ddac507cc65a2c4.jpg
想知道下这个具体的原因可能是啥

回复