Evan说的这个是一个设置，但也仅影响cancel那个命令，stop还是会删除。这个点其实做的不是很好，不清楚为啥，之前Q过，没人鸟。。。 所以按照我的经验，如果是需要停止并基于保存点重启，那还好。如果计划基于检查点重启，无比提前备份检查点，然后停任务，然后复制备份回去。 在或者，直接cancel，不用stop。
Evan <chengyanan1...@foxmail.com> 于2021年1月14日周四 下午6:49写道： > 是的，应该是机制问题，链接[1]打开有这样一句解释： > > If you choose to retain externalized checkpoints on cancellation you have > to handle checkpoint clean up manually when you cancel the job as well > (terminating with job status JobStatus#CANCELED). > > [1] > https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/deployment/config.html#execution-checkpointing-externalized-checkpoint-retention > > 如回答有误，请指正。 > > > > > > > 发件人： yinghua...@163.com > 发送时间： 2021-01-14 18:02 > 收件人： user-zh > 主题： 回复: 回复: 请教个Flink checkpoint的问题 > 代码如下： > streamEnv.enableCheckpointing(5 * 60 * 1000); > CheckpointConfig checkPointConfig = streamEnv.getCheckpointConfig(); > checkPointConfig.setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE); > checkPointConfig.setCheckpointTimeout(1 * 60 * 1000); > checkPointConfig.setMinPauseBetweenCheckpoints((1 * 30 * 1000)); > checkPointConfig.setMaxConcurrentCheckpoints(1); > checkPointConfig.setTolerableCheckpointFailureNumber(3); > checkPointConfig > > .enableExternalizedCheckpoints(ExternalizedCheckpointCleanup.RETAIN_ON_CANCELLATION); > > String checkpointPath = this.execOptions.get(CHECKPOINT_PATH); > try { > StateBackend rocksDBStateBackend = new > RocksDBStateBackend(checkpointPath); > streamEnv.setStateBackend(rocksDBStateBackend); > > > > yinghua...@163.com > > 发件人： Evan > 发送时间： 2021-01-14 17:55 > 收件人： user-zh > 主题： 回复: 请教个Flink checkpoint的问题 > 代码图挂掉了，看不到代码 > > > > 发件人： 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 >
