跳到主要内容

数据集成服务升级(跨版本)

  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 nocoly/hap-flink:版本号
  3. 修改配置文件

    修改 flink.yamlflink-jobmanagerflink-taskmanager 服务使用的镜像版本

    - name: jobmanager
    image: nocoly/hap-flink:版本号
    - name: taskmanager
    image: nocoly/hap-flink:版本号
  4. 重启服务

    kubectl apply -f flink.yaml
  5. 集成中心数据集成同步任务 的任务列表中重新开启/发布任务 💥 💥 💥