scheduler: handle missing err

k3s-v1.15.3
shinytang6 2019-03-29 10:47:58 +08:00
parent b1829dff0b
commit 86515d8b9e
1 changed files with 3 additions and 1 deletions

View File

@ -542,7 +542,9 @@ func (sched *Scheduler) scheduleOne() {
metrics.PodScheduleErrors.Inc()
}
if !approved {
sched.Cache().ForgetPod(assumedPod)
if forgetErr := sched.Cache().ForgetPod(assumedPod); forgetErr != nil {
klog.Errorf("scheduler cache ForgetPod failed: %v", forgetErr)
}
var reason string
if err == nil {
msg := fmt.Sprintf("prebind plugin %v rejected pod %v.", pl.Name(), assumedPod.Name)