1.概述 感谢您抽出 一个flink环境做状态恢复报错:because the operator is not available in the new program。详细错误如下 2.源码分析 2.1 restoreSavepoint restoreSavepoint 是从给定的检查点进行恢复。主要做了如下步骤 检测恢复路径是否存在 从外部存储获取 Checkpoint 元数据,这里的 checkpointStorage 是 FsChec