Flink 1.12 Standalone K8s部署HA服务时出现NullPointerException异常

问题根因 #

从报错栈可以定位到空指针异常出现在Fabric8FlinkKubeClient初始化阶段，对应Flink 1.12版本源码逻辑，该位置是对Kubernetes命名空间参数的非空校验，触发异常的直接原因是flink-conf.yaml中未配置必填的kubernetes.namespace参数，导致Flink创建K8s客户端时获取不到命名空间配置，触发空指针。

另外你当前参考的是Flink 1.13版本的配置文档，和你使用的1.12版本存在配置项差异，1.12版本的Kubernetes原生HA方案要求必须显式配置K8s相关基础参数，才能完成K8s客户端初始化。

解决方案 #

你需要按以下步骤调整配置：

• 在flink-conf.yaml中补充K8s HA必填的基础配置项：

  # 替换为你Flink集群实际部署的K8s命名空间
  kubernetes.namespace: <your-namespace>
  # 与已配置的high-availability.cluster-id保持一致即可
  kubernetes.cluster-id: thoros-cluster-1
  

• 检查JobManager的ServiceAccount权限：Flink K8s HA需要通过K8s的ConfigMap、Endpoints实现Leader选举，需要给JobManager使用的ServiceAccount绑定对应角色，权限需覆盖对configmaps、endpoints、pods资源的get、list、watch、create、update、delete操作权限。
• 修正多JobManager配置逻辑：Job并行度是任务执行的并行配置，和JobManager副本数无关，你需要将JobManager对应的Deployment/StatefulSet的replicas参数设置为2，才能启动一主一备两个JobManager实例。
• 可选优化：Flink 1.12版本的reactive调度模式为实验特性，若完成上述配置后仍有兼容性问题，可先关闭scheduler-mode: reactive配置验证HA功能是否正常。

内容的提问来源于stack exchange，提问作者me_L_coding