C/C++教程

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

本文主要是介绍【Flink】Flink checkpoint 本地磁盘 没有清除,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

文章目录

  • 1.概述

在这里插入图片描述

1.概述

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

在这里插入图片描述
配置如下

flinkProperties:
    state.backend: hashmap
    state.checkpoi
这篇关于【Flink】Flink checkpoint 本地磁盘 没有清除的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!