Flink Checkpoint越来越大是怎么回事

背景

每次 checkpoint 的 StateSize 越来越大,而且查看 checkpoint 文件,还存在历史数据,是什么原因呢?

图片

图片

每次增大的都是在 Window 侧增大的。

同时,查看 checkpoint 文件内容,显示有历史时间,这个时间是什么。

图片

PS:任务是 1.17 启动的

定位问题

首先,checkpoint 目录:chk-n 底下保存的是元数据信息,它的大小随着时间基本是不会变化的,而变化的部分,是 shared 目录。shared 目录底下的文件是怎么写进去的呢?

打开 flink 源代码,全局搜索 shared 关键词。