Re:回复: Re: flink savepoint和checkpoint相关事项

2020-10-09 文章 izual






我理解是一样的,关于两者的不同点在这里[1]有介绍。
恢复方法是启动任务时 -s 指定从哪个路径恢复,例如 -s
file:///tmp/test/db262ffab6b00db9820c54f25a3f956f/chk-61


[1] 
https://ci.apache.org/projects/flink/flink-docs-master/ops/state/savepoints.html#what-is-a-savepoint-how-is-a-savepoint-different-from-a-checkpoint

在 2020-10-10 08:43:38,"zjfpla...@hotmail.com"  写道:
>请问savepoint也是一样吗?
>
>
>
>zjfpla...@hotmail.com
> 
>发件人: Yun Tang
>发送时间: 2020-10-10 01:35
>收件人: user-zh
>主题: Re: flink savepoint和checkpoint相关事项
>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: zjfpla...@hotmail.com 
>Sent: Friday, October 9, 2020 8:59
>To: user-zh 
>Subject: flink savepoint和checkpoint相关事项
> 
>Hi,
>flink的savepoint,checkpoint在任务如何修改的情况下还能沿用,如何修改下就只能重新消费了
> 
> 
> 
>zjfpla...@hotmail.com


回复: Re: flink savepoint和checkpoint相关事项

2020-10-09 文章 zjfpla...@hotmail.com
请问savepoint也是一样吗?



zjfpla...@hotmail.com
 
发件人: Yun Tang
发送时间: 2020-10-10 01:35
收件人: user-zh
主题: Re: flink savepoint和checkpoint相关事项
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: zjfpla...@hotmail.com 
Sent: Friday, October 9, 2020 8:59
To: user-zh 
Subject: flink savepoint和checkpoint相关事项
 
Hi,
flink的savepoint,checkpoint在任务如何修改的情况下还能沿用,如何修改下就只能重新消费了
 
 
 
zjfpla...@hotmail.com


Re: flink savepoint和checkpoint相关事项

2020-10-09 文章 Yun Tang
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: zjfpla...@hotmail.com 
Sent: Friday, October 9, 2020 8:59
To: user-zh 
Subject: flink savepoint和checkpoint相关事项

Hi,
flink的savepoint,checkpoint在任务如何修改的情况下还能沿用,如何修改下就只能重新消费了



zjfpla...@hotmail.com


flink savepoint和checkpoint相关事项

2020-10-08 文章 zjfpla...@hotmail.com
Hi,
flink的savepoint,checkpoint在任务如何修改的情况下还能沿用,如何修改下就只能重新消费了



zjfpla...@hotmail.com