没明白你说的最近一次 checkpoint 被删除啥意思,你可以列一下 checkpoint 目录的内容,你觉得应该是啥,结果是啥。
Best, tison. Evan <chengyanan1...@foxmail.com> 于2021年1月14日周四 下午5:56写道: > 代码图挂掉了,看不到代码 > > > > > 发件人: yinghua...@163.com > 发送时间: 2021-01-14 17:26 > 收件人: user-zh > 主题: 请教个Flink checkpoint的问题 > > 我在yarn上提交任务时,设置flink的checkpoint是5分钟一次,checkpoint使用RocksDBStateBackend保存在HDFS上且任务取消后不删除checkpoint,代码如下 > > 现在我发现,当我停止任务时使用stopWithSavepoint发现任务停止后把最近一次的checkpoint信息给删除了?目前机制是这样的吗还是我使用有问题?是不是调用cancelWithSavepoint停止任务时就不会删除最近一次的checkpoint信息? > > > yinghua...@163.com >