checkpoint问题

classic Classic list List threaded Threaded
3 messages Options
smq
Reply | Threaded
Open this post in threaded view
|

checkpoint问题

smq
如果我的程序逻辑修改,还能用之前的checkpoint吗
Reply | Threaded
Open this post in threaded view
|

Re: checkpoint问题

Yun Tang
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 <[hidden email]>
Sent: Thursday, September 17, 2020 7:02
To: user-zh <[hidden email]>
Subject: checkpoint问题

如果我的程序逻辑修改,还能用之前的checkpoint吗
smq
Reply | Threaded
Open this post in threaded view
|

回复: checkpoint问题

smq
感谢解答

smq

发件人: Yun Tang
发送时间: 2020年9月17日 10:30
收件人: user-zh
主题: Re: checkpoint问题

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 <[hidden email]>
Sent: Thursday, September 17, 2020 7:02
To: user-zh <[hidden email]>
Subject: checkpoint问题

如果我的程序逻辑修改,还能用之前的checkpoint吗