Re: flink on native k8s NodePort方式启动任务后返回的jobmanager web ui的地址不是集群中的ip

Thu, 14 Apr 2022 22:37:56 -0700 

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底层的部署也没发现具体问题
>
>

回复