Hi 在修改作业的情况下，从checkpoint恢复的主要措施是确保相关operator设置了uid[1]，恢复state的时候添加了允许non-restored state [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: [email protected] <[email protected]> Sent: Friday, October 9, 2020 8:59 To: user-zh <[email protected]> Subject: flink savepoint和checkpoint相关事项 Hi， flink的savepoint，checkpoint在任务如何修改的情况下还能沿用，如何修改下就只能重新消费了 [email protected]
