flink k8s HA 报ClusterRetrieveException: Could not get the rest endpoint

文章目录

问题

org.apache.flink.client.deployment.ClusterRetrieveException: Could not get
the rest endpoint of flink-cluster
我是在用flink sql-client 提交任务发现的这个问题

分析

在这里插入图片描述
从源码中可以看到实现上的jobmanager 这个svc要以flink-cluster-rest 来命名才能解析到jobmanager地址