Merge pull request #41357 from freehan/kube-proxy-skip
Automatic merge from submit-queue fix healthcheck update problem introduced by #41223 ref: https://github.com/kubernetes/kubernetes/pull/41223 surgical fix for https://github.com/kubernetes/kubernetes/pull/41223#issuecomment-279120970
This commit is contained in:
commit
b1e0d0ee5e
@ -649,7 +649,17 @@ func (proxier *Proxier) OnEndpointsUpdate(allEndpoints []api.Endpoints) {
|
||||
staleConnections[endpointServicePair{endpoint: ep.ip, servicePortName: svcPort}] = true
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Update service health check
|
||||
allSvcPorts := make(map[proxy.ServicePortName]bool)
|
||||
for svcPort := range proxier.endpointsMap {
|
||||
allSvcPorts[svcPort] = true
|
||||
}
|
||||
for svcPort := range newEndpointsMap {
|
||||
allSvcPorts[svcPort] = true
|
||||
}
|
||||
for svcPort := range allSvcPorts {
|
||||
proxier.updateHealthCheckEntries(svcPort.NamespacedName, svcPortToInfoMap[svcPort])
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user