mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-09-15 06:01:50 +00:00
Merge pull request #22297 from kubernetes/revert-21187-evict
Revert "Evict pods w/o rate-limit when cloud says node is gone."
This commit is contained in:
@@ -479,26 +479,9 @@ func (nc *NodeController) monitorNodeStatus() error {
|
|||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
if remaining {
|
if remaining {
|
||||||
// Immediately evict pods (skip rate-limited evictor)
|
// queue eviction of the pods on the node
|
||||||
glog.V(2).Infof("Deleting node %s is delayed while pods are evicted", node.Name)
|
glog.V(2).Infof("Deleting node %s is delayed while pods are evicted", node.Name)
|
||||||
go func(nodeName string) {
|
nc.evictPods(node.Name)
|
||||||
nc.evictorLock.Lock()
|
|
||||||
defer nc.evictorLock.Unlock()
|
|
||||||
remaining, err := nc.deletePods(nodeName)
|
|
||||||
if err != nil {
|
|
||||||
glog.Errorf("Unable to evict pods from node %s: %v", nodeName, err)
|
|
||||||
nc.podEvictor.Add(nodeName)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
if !remaining {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
// Immediately terminate pods.
|
|
||||||
if _, _, err := nc.terminatePods(nodeName, time.Now()); err != nil {
|
|
||||||
glog.Errorf("Unable to terminate pods on node %s: %v", nodeName, err)
|
|
||||||
nc.terminationEvictor.Add(nodeName)
|
|
||||||
}
|
|
||||||
}(node.Name)
|
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user