Checkpoint使用

[yanggang_it_job]

关于flink从checkpoint的问题：
       1、如果我的并行度发生了改变，怎么从checkpoint启动？
       2、是否可以动态设置checkpoint触发时间？

[Congxian Qiu]

Hi
1. 你可以按照文档[1]从一个 retained checkpoint 进行恢复，并发度可以改变，但是你需要保证最大并发是一样的
2. 不能动态设置 checkpoint 触发时间

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/state/checkpoints.html#resuming-from-a-retained-checkpoint
Best,
Congxian


yanggang_it_job <[hidden email]> 于2019年8月27日周二 下午6:08写道：

> 关于flink从checkpoint的问题：
>        1、如果我的并行度发生了改变，怎么从checkpoint启动？
>        2、是否可以动态设置checkpoint触发时间？

[Andrew Lin]

1，你说的应该是savepoint吧，checkpoint是运行中failover自动恢复的，savepoint如果设置了uid，改变并行度是可以从savepoint启动的

> 下面是被转发的邮件：
>
> 发件人: yanggang_it_job <[hidden email]>
> 主题: Checkpoint使用
> 日期: 2019年8月27日 GMT+8 下午6:08:24
> 收件人: [hidden email]
> 回复－收件人: [hidden email]
>
> 关于flink从checkpoint的问题：
>       1、如果我的并行度发生了改变，怎么从checkpoint启动？
>       2、是否可以动态设置checkpoint触发时间？

[yanggang_it_job]

您说的也对，但是我们重启的时候也是可以从checkpoint启动的。<br/>当我们安装flink的时候可以指定checkpoint的保存地址，同时我们编写任务的时候设置checkpoint的生成规则，当我们需要重启任务的时候直接指定这个地址就可以了。<br/>相对于savepoint来说checkpoint是自动生成的同时更轻量。<br/>所以我们现在是基于checkpoint重启的，然后就遇到了我提的那个问题。
在 2019-08-27 19:57:37，"Andrew Lin" <[hidden email]> 写道：

>1，你说的应该是savepoint吧，checkpoint是运行中failover自动恢复的，savepoint如果设置了uid，改变并行度是可以从savepoint启动的
>
>
>
>> 下面是被转发的邮件：
>>
>> 发件人: yanggang_it_job <[hidden email]>
>> 主题: Checkpoint使用
>> 日期: 2019年8月27日 GMT+8 下午6:08:24
>> 收件人: [hidden email]
>> 回复－收件人: [hidden email]
>>
>> 关于flink从checkpoint的问题：
>>       1、如果我的并行度发生了改变，怎么从checkpoint启动？
>>       2、是否可以动态设置checkpoint触发时间？
>