从理论上来说，要实现你想要的效果，那就需要在start的时候指定上次停止的任务的jobId。 否则flink无法知道你期望基于哪个任务的最后一次检查点继续。反正都是一个参数，为啥不指定ckpt路径或者savepoint路径呢？
Guo Thompson <gwqloveli...@gmail.com> 于2022年2月28日周一 16:51写道： > 要指定savepoint的目录，不然不会从历史状态恢复 > > enginegun <engine_...@163.com> 于2022年2月28日周一 16:38写道： > > > flink 重启任务 进行状态恢复是否必须指定checkpoint目录，能否默认读取最后一次生成的checkpoint 进行状态恢复？ >
