FlinkFlink checkpoint 本地磁盘 没有清除

Posted 九师兄

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了FlinkFlink checkpoint 本地磁盘 没有清除相关的知识,希望对你有一定的参考价值。

文章目录


1.概述

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


配置如下

flinkProperties:
    state.backend: hashmap
    state.checkpoi

以上是关于FlinkFlink checkpoint 本地磁盘 没有清除的主要内容,如果未能解决你的问题,请参考以下文章

FlinkFlink 监控 Checkpoint

FlinkFlink 清理过期 Checkpoint 目录的正确姿势

FlinkFlink Checkpoint 问题排查实用指南

FlinkFlink 反压机制 导致checkpoint 失败

FlinkFlink 新一代流计算和容错 Unaligned Checkpoint快速Checkpoint更小的Checkpoint

FlinkFlink Exceeded checkpoint tolerable failure threshold