diff --git a/cluster/addons/fluentd-elasticsearch/es-image/elasticsearch_logging_discovery.go b/cluster/addons/fluentd-elasticsearch/es-image/elasticsearch_logging_discovery.go
index cf283dbf9b0..75f728662d7 100644
--- a/cluster/addons/fluentd-elasticsearch/es-image/elasticsearch_logging_discovery.go
+++ b/cluster/addons/fluentd-elasticsearch/es-image/elasticsearch_logging_discovery.go
@@ -113,7 +113,7 @@ func main() {
 		}
 		addrs = flattenSubsets(endpoints.Subsets)
 		glog.Infof("Found %s", addrs)
-		if len(addrs) > 0 && len(addrs) == count {
+		if len(addrs) > 0 && len(addrs) >= count {
 			break
 		}
 	}