diff --git a/spring-cloud-kubernetes-client-discovery/src/main/java/org/springframework/cloud/kubernetes/client/discovery/KubernetesInformerDiscoveryClient.java b/spring-cloud-kubernetes-client-discovery/src/main/java/org/springframework/cloud/kubernetes/client/discovery/KubernetesInformerDiscoveryClient.java index bf47b9c2..f8ccd5a6 100644 --- a/spring-cloud-kubernetes-client-discovery/src/main/java/org/springframework/cloud/kubernetes/client/discovery/KubernetesInformerDiscoveryClient.java +++ b/spring-cloud-kubernetes-client-discovery/src/main/java/org/springframework/cloud/kubernetes/client/discovery/KubernetesInformerDiscoveryClient.java @@ -119,7 +119,7 @@ public class KubernetesInformerDiscoveryClient implements DiscoveryClient, Initi V1Endpoints ep = this.endpointsLister.namespace(service.getMetadata().getNamespace()) .get(service.getMetadata().getName()); - if (ep == null) { + if (ep == null || ep.getSubsets() == null) { // no available endpoints in the cluster return new ArrayList<>(); }