如下是 describe svc my-first-flink-cluster-rest 的结果: Name: my-first-flink-cluster-rest Namespace: default Labels: app=my-first-flink-cluster type=flink-native-kubernetes Annotations: <none> Selector: app=my-first-flink-cluster,component=jobmanager,type=flink-native-kubernetes Type: LoadBalancer IP Family Policy: SingleStack IP Families: IPv4 IP: 192.168.127.57 IPs: 192.168.127.57 Port: rest 8081/TCP TargetPort: 8081/TCP NodePort: rest 31419/TCP Endpoints: 192.168.130.11:8081 Session Affinity: None External Traffic Policy: Cluster Events: <none>
如上,其中IP为192.168.127.57,这个是ClusterIp是可以访问的。我是不知道为啥创建之后提示的地址不是这个,而且通过 -Dkubernetes.cluster-id=my-first-flink-cluster检索到的地址也不是192那个,导致无法提交任务等。 yu'an huang <h.yuan...@gmail.com> 于2022年4月8日周五 02:11写道: > > 理论上cluster ip是不可能在集群外访问的,你的Kubernetes环境是怎么搭建的呢?Minikube吗? > > 方便的话可以分享你运行这个命令的结果吗? > 》kubectl describe svc my-first-flink-cluster-rest > > > > > On 7 Apr 2022, at 4:44 PM, Zhanghao Chen <zhanghao.c...@outlook.com> wrote: > > > > 你 kubernetes.rest-service.exposed.type 这个参数设置的是什么呢? > > > > Best, > > Zhanghao Chen > > ________________________________ > > From: yidan zhao <hinobl...@gmail.com> > > Sent: Thursday, April 7, 2022 11:41 > > To: user-zh <user-zh@flink.apache.org> > > Subject: k8s session cluster flink1.13.6创建后提示的地址啥用。 > > > > 参考 > > https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/deployment/resource-providers/native_kubernetes/#starting-a-flink-session-on-kubernetes > > > > 基于命令创建k8s flink session集群(flink1.13.6):./bin/kubernetes-session.sh > > -Dkubernetes.cluster-id=my-first-flink-cluster 。创建成功,最后提示一句 Create > > flink session cluster my-first-flink-cluster successfully, JobManager > > Web Interface: http://10.227.137.154:8081。但是这个地址访问不通。 > > > > 并且通过如下命令提交任务也一样,会检索到如上地址,然后提交任务不成功。 > > ./bin/flink run \ > > --target kubernetes-session \ > > -Dkubernetes.cluster-id=my-first-flink-cluster \ > > ./examples/streaming/TopSpeedWindowing.jar > > > > --- 然后如下方式是可以的,不清楚是啥问题呢。 > > 1 通过 kubectl get svc 拿到 my-first-flink-cluster-rest > > 的clusterIp:port为192.168.127.57:8081。 > > 2 查看任务 > > flink list -m 192.168.127.57:8081 > > 3 提交任务 > > flink run -m 192.168.127.57:8081 > > /home/work/flink/examples/streaming/TopSpeedWindowing.jar > > > > --- 区别:192这个是clusterIp虚拟ip。 10.x那个是我机器ip。 >