flink checkpoint 保留机制问题 集群模式是 standlane模式 我设置参数sta[阿里云实时计算 Flink版]

flink checkpoint 保留机制问题 集群模式是 standlane模式 我设置参数state.checkpoints.num-retained 参数为2 清除策略设置 RETAIN_ON_CANCELLATION

出现的问题就是:主节点中chk-xxx 文件有删除 但工作节点中的shared目录下的引用文件未删除,时间一长会导致磁盘爆满,跟了下代码 删除操作是在主节点进行的没有看到工作节点的删除逻辑。

想问下群里的大佬有没有遇到过类似的问题或者熟悉checkpoint这块保留策略的机制

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====