diff --git a/pkg/proxy/roundrobbin.go b/pkg/proxy/roundrobbin.go index e1526be1998..a55d10d5ccc 100644 --- a/pkg/proxy/roundrobbin.go +++ b/pkg/proxy/roundrobbin.go @@ -84,9 +84,10 @@ func (impl LoadBalancerRR) OnUpdate(endpoints []api.Endpoints) { // First update / add all new endpoints for services. for _, value := range endpoints { existingEndpoints, exists := impl.endpointsMap[value.Name] - if !exists || !reflect.DeepEqual(value.Endpoints, existingEndpoints) { + validEndpoints := impl.FilterValidEndpoints(value.Endpoints) + if !exists || !reflect.DeepEqual(existingEndpoints, validEndpoints) { glog.Infof("LoadBalancerRR: Setting endpoints for %s to %+v", value.Name, value.Endpoints) - impl.endpointsMap[value.Name] = impl.FilterValidEndpoints(value.Endpoints) + impl.endpointsMap[value.Name] = validEndpoints // Start RR from the beginning if added or updated. impl.rrIndex[value.Name] = 0 }