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>