如下是 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。
>

回复