数据集成服务升级（跨版本）

1. 删除 ConfigMap 清理 Job 列表，找到 ConfigMap 相关配置，如下示例：

   kubernetes.cluster-id: md-flink
   kubernetes.namespace: default

   执行脚本批量删除 ConfigMap

   如果未输出 configmap "md-flink" deleted 之类字样，则表示命名空间或者 ConfigMap 前缀错误，需要再次检查

   # for i in $(kubectl -n 【此处替换为 kubernetes.namespace 的值】 get cm | awk '$1~"【此处替换为 kubernetes.cluster-id 的值】"{print $1}');do kubectl -n 【此处替换为 kubernetes.namespace 的值】 delete cm $i;done
   
   for i in $(kubectl -n default get cm | awk '$1~"md-flink"{print $1}');do kubectl -n default delete cm $i;done

2. 下载新版本镜像（离线包下载）

   kubernetes 集群中各节点服务器上都需要操作

   crictl pull registry.cn-hangzhou.aliyuncs.com/mdpublic/mingdaoyun-flink:版本号

3. 修改配置文件

   修改 flink.yaml 中 flink-jobmanager 与 flink-taskmanager 服务使用的镜像版本

   - name: jobmanager
     image: registry.cn-hangzhou.aliyuncs.com/mdpublic/mingdaoyun-flink:版本号
   - name: taskmanager
     image: registry.cn-hangzhou.aliyuncs.com/mdpublic/mingdaoyun-flink:版本号

4. 重启服务

   kubectl apply -f flink.yaml

5. 在 集成中心 》数据集成 》同步任务 的任务列表中重新开启/发布任务 💥 💥 💥