感谢 我看下这块 huweihua <huweihua....@gmail.com> 于2022年4月15日周五 13:47写道：
> Nodeport 模式下获取 address 的代码在 getLoadBalancerRestEndpoint 中。历史版本会直接获取k8s > master url, 在 Flink-1.14 版本中针对 k8s master 是 VIP 的情况做了适配[1]，可以看下是否对你有帮助 > https://issues.apache.org/jira/browse/FLINK-23507 > > > > 2022年4月15日 下午1:37，shimin huang <huangshimin1...@gmail.com> 写道： > > > > Fabric8FlinkKubeClient#getRestEndPointFromService > > > > > > shimin huang <huangshimin1...@gmail.com> 于2022年4月15日周五 13:37写道： > > > >> private Optional<Endpoint> getRestEndPointFromService(Service service, > int restPort) { > >> if (service.getStatus() == null) { > >> return Optional.empty(); > >> } > >> > >> LoadBalancerStatus loadBalancer = > service.getStatus().getLoadBalancer(); > >> boolean hasExternalIP = > >> service.getSpec() != null > >> && service.getSpec().getExternalIPs() != null > >> && !service.getSpec().getExternalIPs().isEmpty(); > >> > >> if (loadBalancer != null) { > >> return getLoadBalancerRestEndpoint(loadBalancer, restPort); > >> > >> // 理解主要这块代码，nodeport方式 > >> } else if (hasExternalIP) { > >> final String address = service.getSpec().getExternalIPs().get(0); > >> if (address != null && !address.isEmpty()) { > >> return Optional.of(new Endpoint(address, restPort)); > >> } > >> } > >> return Optional.empty(); > >> } > >> > >> > >> huweihua <huweihua....@gmail.com> 于2022年4月15日周五 11:35写道： > >> > >>> 图片显示失败了，可以上传到图床，贴链接到邮件里 > >>> > >>>> 2022年4月15日 上午11:30，shimin huang <huangshimin1...@gmail.com> 写道： > >>>> > >>>> > >>>> 具体细节看和flink k8s这块的细节实现有关，不清楚为什么这个externalIPs的第一个ip在我们k8s集群中为什么不存在 > >>>> > >>>> shimin huang <huangshimin1...@gmail.com <mailto: > >>> huangshimin1...@gmail.com>> 于2022年4月15日周五 11:16写道： > >>>> hi，使用flink on native k8s NodePort方式启动任务后返回的jobmanager web > >>> ui的地址不是集群中的ip，看k8s底层的部署也没发现具体问题 > >>> > >>> > >
