Flinkflink 状态恢复 because the operator is not available in the new program
Posted 九师兄
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flinkflink 状态恢复 because the operator is not available in the new program相关的知识，希望对你有一定的参考价值。
1.概述
感谢您抽出
一个flink环境做状态恢复报错：because the operator is not available in the new program。详细错误如下
2.源码分析
2.1 restoreSavepoint
restoreSavepoint 是从给定的检查点进行恢复。主要做了如下步骤
- 检测恢复路径是否存在
- 从外部存储获取 Checkpoint 元数据，这里的 checkpointStorage 是 FsChec
以上是关于Flinkflink 状态恢复 because the operator is not available in the new program的主要内容，如果未能解决你的问题，请参考以下文章
FlinkFlink 状态恢复报错 StateMigrationException For heap backendsthe new state serializer must not be
FLinkFlink checkpoint 实现数据连续计算 恢复机制 案例实战
flinkflink 消费组死掉 Lag不变 kafka不提交 重启恢复 非常诡异
FLinkFLink Mertic 冲突 导致 任务挂掉 Namecollision Group allready contains a mertics