From 6410ac3173148d88e454830243a1c263b9f87b10 Mon Sep 17 00:00:00 2001 From: caiweidong Date: Sat, 23 Nov 2019 11:30:42 +0800 Subject: [PATCH] Return when removePod failed --- pkg/scheduler/internal/cache/cache.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pkg/scheduler/internal/cache/cache.go b/pkg/scheduler/internal/cache/cache.go index d740c0625d9..77a3cea16e6 100644 --- a/pkg/scheduler/internal/cache/cache.go +++ b/pkg/scheduler/internal/cache/cache.go @@ -407,7 +407,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)