1 files changed, 6 insertions, 10 deletions
diff --git a/plugin/kubernetes/local.go b/plugin/kubernetes/local.go
index 7a85de1bf..e15fec497 100644
--- a/plugin/kubernetes/local.go
+++ b/plugin/kubernetes/local.go
@@ -28,18 +28,14 @@ func (k *Kubernetes) localNodeName() string {
 	}
 
 	// Find endpoint matching localIP
-	ep := k.APIConn.EpIndexReverse(localIP.String())
-	if ep == nil {
-		return ""
-	}
-
-	for _, eps := range ep.Subsets {
-		for _, addr := range eps.Addresses {
-			if localIP.Equal(net.ParseIP(addr.IP)) {
-				return addr.NodeName
+	for _, ep := range k.APIConn.EpIndexReverse(localIP.String()) {
+		for _, eps := range ep.Subsets {
+			for _, addr := range eps.Addresses {
+				if localIP.Equal(net.ParseIP(addr.IP)) {
+					return addr.NodeName
+				}
 			}
 		}
 	}
-
 	return ""
 }