flink sql 如何指定之前的checkpoint执行？
- hi，大家好，我遇到个问题，执行一个sql，作了checkpoint，现在sql中加了where条件，但是insert select 的值都没变，想指定之前的checkpoint继续执行，但是会报错，cannot map checkpoint state for operator *** to the new programe 是不是因为sql改变了，算子id就变了找不到了，这个有什么办法吗？ *来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
如果你的算子有改变的话，想从 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*来自志愿者整理的flink
2021-12-07 21:00:08赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
