1 files changed, 10 insertions, 6 deletions
diff --git a/plugin/kubernetes/local.go b/plugin/kubernetes/local.go
index e15fec497..7a85de1bf 100644
--- a/plugin/kubernetes/local.go
+++ b/plugin/kubernetes/local.go
@@ -28,14 +28,18 @@ func (k *Kubernetes) localNodeName() string {
 	}
 
 	// Find endpoint matching localIP
-	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
-				}
+	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
 			}
 		}
 	}
+
 	return ""
 }