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具体指的是什么呢? >