全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

Flink中检查点清理策略是什么？

提问者：帅平问题分类：面试刷题

Flink中检查点清理策略是什么？

Flink面试题 Flink

发布于：7小时前 IP属地：

1 个回答

我是蓝天梦

检查点清理策略（Checkpoint Cleanup Strategy）用于管理已生成的检查点文件的生命周期，避免过期的检查点占用过多存储资源。涉及到的清理测量有：
1、自动清理策略配置

# 保留最近的10个检查点
state.checkpoints.num-retained: 10
# 或基于时间的保留（Flink 1.15+）
state.checkpoints.cleanup.retain.time: 7d

2、外部化检查点清理策略

env.getCheckpointConfig().setExternalizedCheckpointCleanup(
    CheckpointConfig.ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION
);

当然还可以手动清理检查点，例如：

# 删除指定检查点目录
hdfs dfs -rm -r hdfs:///checkpoints/<checkpoint-id>

发布于：7小时前 IP属地：

我来回答