【Flink】flink 状态恢复 because the operator is not available in the new program
创始人
2024-03-14 13:47:57
0

在这里插入图片描述

1.概述

感谢您抽出

d8ecf8f7cdd8d9b7e0826c850ad06ad8.gif 535eeda53630e8537f22b0d62955c5fa.gif 0e3916616ab817aa003fb7fd1f121978.gif

一个flink环境做状态恢复报错:because the operator is not available in the new program。详细错误如下

在这里插入图片描述

2.源码分析

2.1 restoreSavepoint

restoreSavepoint 是从给定的检查点进行恢复。主要做了如下步骤

  1. 检测恢复路径是否存在
  2. 从外部存储获取 Checkpoint 元数据,这里的 checkpointStorage 是 FsChec

相关内容

热门资讯

监控摄像头接入GB28181平... 流程简介将监控摄像头的视频在网站和APP中直播,要解决的几个问题是:1&...
Windows10添加群晖磁盘... 在使用群晖NAS时,我们需要通过本地映射的方式把NAS映射成本地的一块磁盘使用。 通过...
protocol buffer... 目录 目录 什么是protocol buffer 1.protobuf 1.1安装  1.2使用...
在Word、WPS中插入AxM... 引言 我最近需要写一些文章,在排版时发现AxMath插入的公式竟然会导致行间距异常&#...
Fluent中创建监测点 1 概述某些仿真问题,需要创建监测点,用于获取空间定点的数据࿰...
educoder数据结构与算法...                                                   ...
MySQL下载和安装(Wind... 前言:刚换了一台电脑,里面所有东西都需要重新配置,习惯了所...
MFC文件操作  MFC提供了一个文件操作的基类CFile,这个类提供了一个没有缓存的二进制格式的磁盘...
有效的括号 一、题目 给定一个只包括 '(',')','{','}'...
【Ctfer训练计划】——(三... 作者名:Demo不是emo  主页面链接:主页传送门 创作初心ÿ...