flin的checkpoint文件持续增加,如何解决?-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

flin的checkpoint文件持续增加,如何解决?

游客jxpuxc3cxukgg 2021-01-06 16:45:07 287

有个问题,我用docker部署的,就是我用FsStateBackend(地址是本地) 设置state.checkpoints.num-retained: 10,在jobmanager上看检查点一直都是10个 但是在taskmanager上看地址,就发现检查点的文件夹持续增加。这正常吗? 正常不应该只有jobmanage有文件吗,taskmanger不应该有检查点的文件

checkpoint如何解决 如何解决文件 如何解决int check文件 checkpoint文件
分享到
取消 提交回答
全部回答(1)
  • 游客jxpuxc3cxukgg
    2021-01-06 21:01:38

    找到问题了,查看了taskManager的check-n文件,发现是org.apache.flink.api.common.typeutils.base.StringSerializer$StringSerializerSnapshot,应该是序列化问题, 发现循环的Bean属性太多,所以吧Bean的属性减少些没有用的,发现taskmanager没有新的文件生成

    0 0

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

推荐文章
相似问题
最新问题
推荐课程
链接