谢谢回复。 原来是这样，我原来还以为intermediate savepoints 指代的是checkpoint呢，我们这边的Flink平台正在做从ckp的状态恢复所以才有此一问。
Jiangang Liu <liujiangangp...@gmail.com> 于2022年4月22日周五 19:52写道： > intermediate > > savepoints指的是非stop-with-savepoint，也就是不停止作业的情况下做savepoint。我的感觉是，这个时候的savepoint不会commit（比如sink写出到外部系统），如果作业失败会从最近一次的checkpoint恢复。如果恰好有一个作业从savepoint恢复，两个作业同时跑，可能会造成结果的重复或者不一致，这个时候最好丢弃掉sink（换uid）。对于只有一个作业运行的情况，比如停了作业再恢复，是不会有问题的。 > > 林影 <brucekel...@gmail.com> 于2022年4月22日周五 17:05写道： > > > 在Flink 官网savepoint的页面中，出现下面一段话 > > Starting from Flink 1.15 intermediate savepoints (savepoints other than > > created with stop-with-savepoint > > < > > > https://nightlies.apache.org/flink/flink-docs-master/docs/ops/state/savepoints/#stopping-a-job-with-savepoint > > >) > > are not used for recovery and do not commit any side effects. > > > > intermediate savepoints具体指的是什么呢？ > > >
