跳到主要内容

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. 修改配置​

编辑 flink.yaml 配置文件，将 flink 服务的镜像版本标签修改为目标版本：

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

执行以下脚本重新部署服务：

1. 停止当前服务

docker stack rm flink

2. 启动新版本服务

等待 docker ps 命令不再输出 Flink 相关容器后，执行部署：

docker stack deploy -c flink.yaml flink

5. 重新发布任务​

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