Hi checkpoint使用operator id进行一一映射进行恢复,请参照 设置id[1],以及如果checkpoint中存在某个operator但是修改后的作业并不存在该operator时的处理逻辑[2]
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/state/savepoints.html#assigning-operator-ids [2] https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/state/savepoints.html#allowing-non-restored-state 祝好 唐云 ________________________________ From: smq <[email protected]> Sent: Thursday, September 17, 2020 7:02 To: user-zh <[email protected]> Subject: checkpoint问题 如果我的程序逻辑修改,还能用之前的checkpoint吗
