mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-23 11:50:44 +00:00
Merge pull request #85561 from cwdsuzhou/Nov/return_when_failed
Return when removePod failed
This commit is contained in:
commit
862c8bf818
4
pkg/scheduler/internal/cache/cache.go
vendored
4
pkg/scheduler/internal/cache/cache.go
vendored
@ -469,7 +469,9 @@ func (cache *schedulerCache) AddPod(pod *v1.Pod) error {
|
||||
// The pod was added to a different node than it was assumed to.
|
||||
klog.Warningf("Pod %v was assumed to be on %v but got added to %v", key, pod.Spec.NodeName, currState.pod.Spec.NodeName)
|
||||
// Clean this up.
|
||||
cache.removePod(currState.pod)
|
||||
if err = cache.removePod(currState.pod); err != nil {
|
||||
klog.Errorf("removing pod error: %v", err)
|
||||
}
|
||||
cache.addPod(pod)
|
||||
}
|
||||
delete(cache.assumedPods, key)
|
||||
|
Loading…
Reference in New Issue
Block a user