flink checkpoint 数据清理问题怎么做？
背景：1.flink 集群模式 standalone HA ，共三台，zk选举jobmanager，1 active 1 standby 2.文件系统由于公司原因，没有用hdfs，用的本地文件系统 3.backend用的增量rocksdb
配置情况：
进程分布情况如下:
问题：checkpoint数据在01（01是主jobmanager）上占用很小，但在02、03节点增长特别快，目前已占用数据盘90%的存储。 但由于使用的是增量rocksdb，不敢随意删chekpoint数据，想问问大佬们： 1.是否有办法让flink自动清理过期checkpoint，还是只能通过加磁盘方式解决？ 2.我一直认为checkpoint数据是由主jobmanager触发写的，那么在当前情况应该只有01节点会写入checkpoint（本地磁盘），为什么02、03节点也会写入checkpoint，而且写入量比01大那么多？*来自志愿者整理的flink邮件归档
展开
收起
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
