【Flink】Flink checkpoint 本地磁盘 没有清除

文章目录


【Flink】Flink checkpoint 本地磁盘 没有清除

1.概述

有这样一个问题,就是我的checkpoint地址配置的是本地磁盘,然后我配置了只保留最新的五个checkpoint,但是我看taskmanager磁盘上checkpoint的数据会一直保留。这个应该怎么处理呢?

【Flink】Flink checkpoint 本地磁盘 没有清除
配置如下

flinkProperties:
    state.backend: hashmap
    state.checkpoi
上一篇:Flink处理--异步IO


下一篇:提交flink程序到集群上