Hi 嘉贤,

Flink Web上展示的Checkpoint的历史记录,state-checkpoints.num-retained参数会控制在Checkpoint 
storage中存储的checkpoint数量,Flink会滚动删除Checkpoint storage的checkpoint文件,但是这个过程中Flink 
Web上记录是不会删除的(你可以在对应的Checkpoint记录的Path上的地址去确认)。
同时,如果你是Heap 
StateBackend,那么状态是存储到内存里的,checkpoint是flush到文件的。之所以内存增大大概率是任务本身导致的,而非历史Checkpoint导致(例如全局窗口聚合且未设置State
 TTL的场景),如果要定位内存上涨的原因还需要更多的作业信息。
另外,如果你希望确认参数是否生效,可以在JobManager的Configuration一栏查看。

Best,
Yu Chen

> 2023年11月8日 11:56,梁嘉贤 <lian...@sutpc.com> 写道:
> 
> 您好,
>       采用Flink 1.14 
> 版本,用docker分别建立了jobmanger和taskmanager两个容器,docker-compose.yml信息如下图1所示。
>       在配置中,设置了state.checkpoints.num-retained : 
> 1,但在web中看到checkpoint持续增多(下图2),在taskmanager容器中的checkpoint数量也持续增多,请问可以怎么清理这些历史checkpoint吗?
>   
> <b2f07...@09951a67.eb064b6500000000.png><03b4c...@04cd7323.eb064b6500000000.png>

Reply via email to