集群是3台物理机搭建,非minikube。 不清楚是否和网卡有关,init搭建时就有网络问题,k8s要根据默认路由网卡ip决定监听的地址。 但是我感觉这个场景不应该,因为既然是clusterIp,创建后提示信息就应该提示用clusterIp吧,为啥提示的用了本机的网卡ip呢。
yidan zhao <hinobl...@gmail.com> 于2022年4月8日周五 10:38写道: > > 如下是 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。 > >