Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
checkpoint问题
Classic
List
Threaded
♦
♦
Locked
3 messages
smq
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
checkpoint问题
如果我的程序逻辑修改,还能用之前的checkpoint吗
Yun Tang
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
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吗
smq
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
回复: checkpoint问题
感谢解答
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吗
Free forum by Nabble
Edit this page