跳到主要内容

Flink 同服务器部署（跨版本升级）

1. 镜像拉取​

请在 Flink 节点上根据架构拉取目标版本的应用镜像（离线包下载）。

docker pull registry.cn-hangzhou.aliyuncs.com/mdpublic/mingdaoyun-flink:1.19.720

2. 清理 Job 运行记录​

跨版本升级前，需清理旧版的作业状态。请执行以下命令进入容器并完成数据清理：

1. 进入容器

docker exec -it $(docker ps | grep mingdaoyun-flink | awk '{print $1}') bash

2. 备份并清理数据

# 备份并清空旧版本的 Job 列表数据
mv /data/flink/zookeeper /data/flink/zookeeper.backup-$(date +%Y%m%d%H%M%S)

3. 修改配置​

编辑 /data/mingdao/script/docker-compose.yaml 配置文件，将 flink 服务的镜像版本标签修改为目标版本：

# 示例配置片段
flink:
  image: registry.cn-hangzhou.aliyuncs.com/mdpublic/mingdaoyun-flink:1.19.720

4. 重启服务​

在管理器根目录下执行以下脚本重启服务：

bash ./service.sh restartall
如遗忘 service.sh 文件所在路径，点击查看查找命令
find / -path /proc -prune -o -name "service.sh" -print

5. 重新发布任务​

升级完成后，请手动在同步任务列表将相关任务重新开启/发布任务，同步任务才会恢复正常工作。