恢复Flink元数据

操作场景

在用户意外修改、删除或需要找回数据时，系统管理员需要对Flink进行重大操作（如升级或迁移等）后，系统数据出现异常或未达到预期结果，导致Flink组件全部故障无法使用，或者迁移数据到新集群的场景中，需要对Flink元数据进行恢复数据操作。

用户可以通过FusionInsight Manager创建恢复Flink元数据任务，系统仅支持手动进行数据恢复。

MRS集群支持多种数据路径类型恢复Flink元数据：

• LocalDir：表示从主管理节点的本地磁盘上恢复数据。
• LocalHDFS：表示从当前集群的HDFS目录恢复数据。
• RemoteHDFS：表示从备集群的HDFS目录恢复数据。
• OBS：表示从OBS中恢复数据。

约束与限制

• 只支持进行数据备份时的系统版本与当前系统版本一致时的数据恢复。
• Flink元数据恢复和业务数据恢复不能同时进行操作，否则会导致业务数据恢复失败。建议元数据恢复完成后再进行业务数据恢复。
• MRS 3.5.0及之后版本，支持从OBS中恢复数据。

对系统的影响

• 元数据恢复前，需要停止Flink服务，在这期间所有上层应用都会受到影响，无法正常工作。
• 元数据恢复后，会丢失从备份时刻到恢复时刻之间的数据。
• 元数据恢复后，需要重新启动Flink的上层应用。

前提条件

• 检查Flink元数据备份文件保存路径。
• 恢复Flink元数据需要先停止Flink服务。
• 如果需要从远端HDFS恢复数据，需要准备备集群，且已完成数据备份，详细操作请参见备份Flink元数据。如果主集群部署为安全模式，且主备集群不是由同一个FusionInsight Manager管理，则必须配置系统互信，请参见配置MRS集群间互信。如果主集群部署为普通模式，则不需要配置互信。
• 主备集群必须已配置跨集群拷贝，请参见启用MRS集群间拷贝功能。

恢复Flink元数据

1. 登录MRS集群Manager界面。

   登录集群Manager界面请参考访问MRS集群Manager。

2. 选择 “运维 > 备份恢复 > 备份管理”。
3. 在任务列表指定任务的“操作”列，选择“更多 > 查询历史”。

   在弹出的窗口中，指定一次成功执行的“备份路径”，单击“查看”，打开此次任务执行的备份路径信息，查找以下信息：

   • “备份对象”表示备份的数据源。
   • “备份路径”表示备份文件保存的完整路径。

     选择正确的项目，在“备份路径”中选中备份文件的完整路径并复制。

4. 在FusionInsight Manager，选择“运维 > 备份恢复 > 恢复管理”。
5. 单击“创建”。
6. 在“任务名称”填写恢复任务的名称。
7. 在“恢复对象”选择待操作的集群。
8. 在“恢复配置”，勾选“元数据和其他数据”下的“Flink”。
9. 在“Flink”的“路径类型”，选择一个恢复目录的类型。

   表1 恢复数据

   类型	配置参数	参数描述
   LocalDir	源端路径	表示要恢复的备份文件。例如，“版本号_数据源_任务执行时间.tar.gz”。
   LocalHDFS	源端路径	备份文件在HDFS中保存的完整路径。例如“备份路径/备份任务名_任务创建时间/版本号_数据源_任务执行时间.tar.gz”。
   	源NameService名称	恢复任务执行时备份目录对应的NameService名称。默认值为“hacluster”。
   RemoteHDFS	源端NameService名称	备份数据集群的NameService名称。可以输入集群内置的远端集群的NameService名称：haclusterX，haclusterX1，haclusterX2，haclusterX3，haclusterX4；也可输入其他已配置的远端集群NameService名称。
   	IP 模式	目标IP的IP地址模式。系统会根据集群网络类型自动选择对应的IP模式，如IPv4或者IPv6。
   	源端NameNode IP地址	备集群NameNode业务平面IP地址，支持主节点或备节点。
   	源端路径	备集群保存备份数据的完整HDFS路径。例如，“备份路径/备份任务名_数据源_任务创建时间/版本号_数据源_任务执行时间.tar.gz”。
   	队列名称	备份任务执行时使用的YARN队列的名称。需和集群中已存在且状态正常的队列名称相同。
   OBS（仅MRS 3.5.0及之后版本支持）	源端路径	备份文件在OBS中保存的完整路径。例如，“备份路径/备份任务名_数据源_任务创建时间/版本号_数据源_任务执行时间.tar.gz”。

10. 单击“确定”保存。
11. 在恢复任务列表已创建任务的“操作”列，单击“执行”，在弹出窗口上继续单击“确定”，开始执行恢复任务。
    • 恢复成功后进度显示为绿色。
    • 恢复成功后此恢复任务不支持再次执行。
    • 如果恢复任务在第一次执行时由于某些原因未执行成功，在排除错误原因后单击“重试”，重试恢复任务。

12. 在“集群 > 服务”页面，启动Flink服务。