flink sql 如何指定之前的checkpoint执行

[superainbower]

hi，大家好，我遇到个问题，执行一个sql，作了checkpoint，现在sql中加了where条件，但是insert select 的值都没变，想指定之前的checkpoint继续执行，但是会报错，cannot map checkpoint state for operator *** to the new programe 是不是因为sql改变了，算子id就变了找不到了，这个有什么办法吗

[JasonLee]

hi
可以参考这篇文章https://mp.weixin.qq.com/s/Vl6_GsGeG0dK84p9H2Ld0Q
在cancel的时候触发一个savepoint 修改完SQL从savepoint恢复任务



--
Sent from: http://apache-flink.147419.n8.nabble.com/

[Congxian Qiu]

Hi
    如果你的算子有改变的话，想从 checkpoint/savepoint 恢复，需要添加
`--allowNonRestoredState`，这样可以忽略掉那些不在新
job 中的算子（就算逻辑一样，uid 不一样也会被忽略掉的），具体的可以参考文档[1]

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.11/ops/state/savepoints.html#what-happens-if-i-delete-an-operator-that-has-state-from-my-job

Best,
Congxian


JasonLee <[hidden email]> 于2020年8月19日周三 上午11:29写道：

> hi
> 可以参考这篇文章https://mp.weixin.qq.com/s/Vl6_GsGeG0dK84p9H2Ld0Q
> 在cancel的时候触发一个savepoint 修改完SQL从savepoint恢复任务
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>