Hi amenhub, 我这边针对你这三个问题回答一下：
1. 官网描述的[when program is cancelled]，这个cancelled是指除故障导致停止之外的一切任务停止方式吗？ 这里的 canceled 主要是针对你使用 cancel 或者 cancel with savepoint 来停止作业，你可以通过命令行或者 REST API 来调用。 2.如果是，在flink on yarn模式下，停止任务时采取 yarn application -kill [yarnAppId] 形式停止flink任务，chk似乎没有自动删除？ 是的，如果你直接 yarn kill 你的 Flink 任务，Flink 任务的 Checkpoint 文件不会进行清理，还是会保留在 HDFS 上面。 3. 假如不能删除，是否需要像trigger savepoint那样采用 stop 命令进行优雅的停止，chk才会自动删除？ 目前 FLIP-34 建议用户如果需要停止作业的时候，触发 Savepoint，可以使用 stop 命令来停止。如果你不需要触发 Savepoint，也可以使用 cancel. 具体信息可以参考下列文档： [1] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=103090212 [2] https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/cli.html#stop Best wishes, 沈磊 [email protected] <[email protected]> 于2020年3月20日周五 下午3:35写道： > hi, everyone > > 官网描述当flink program is cancelled，此时的flink默认会删除chk。 > > 我的疑问是： > 1.官网描述的[when program is cancelled]，这个cancelled是指除故障导致停止之外的一切任务停止方式吗？ > 2.如果是，在flink on yarn模式下，停止任务时采取 yarn application -kill [yarnAppId] > 形式停止flink任务，chk似乎没有自动删除？ > 3.假如不能删除，是否需要像trigger savepoint那样采用 stop 命令进行优雅的停止，chk才会自动删除？ > 注：我的flink程序通过SQL提交，以on yarn模式运行。 > Best > amenhub > > > > [email protected] >
