说一下我们平台的实现方式 1、自定义metricReporter，假如任务开启了checkpoint，reporter会自动的将最新完成的checkpoint路径进行上报 可参考https://ci.apache.org/projects/flink/flink-docs-release-1.11/monitoring/metrics.html#checkpointing 2、平台会有是否重试和是否基于checkpoint进行恢复的选项 3、假如上述两选项都开启了之后，可以对运行失败的任务基于最新的checkpoint进行拉起
-- Sent from: http://apache-flink.147419.n8.nabble.com/
