flink checkpoint 保留机制问题 集群模式是 standlane模式 我设置参数state.checkpoints.num-retained 参数为2 清除策略设置 RETAIN_ON_CANCELLATION
出现的问题就是:主节点中chk-xxx 文件有删除 但工作节点中的shared目录下的引用文件未删除,时间一长会导致磁盘爆满,跟了下代码 删除操作是在主节点进行的没有看到工作节点的删除逻辑。
想问下群里的大佬有没有遇到过类似的问题或者熟悉checkpoint这块保留策略的机制