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吗

回复