Skip to content

Commit

Permalink
!172 【修改说明 Modification】volcano重调度查pod超时bug修复
Browse files Browse the repository at this point in the history
Merge pull request !172 from fengjianqing/master
  • Loading branch information
autoxj authored and gitee-org committed Dec 14, 2023
2 parents 724fe60 + 631eada commit 27bdfa5
Showing 1 changed file with 1 addition and 9 deletions.
10 changes: 1 addition & 9 deletions internal/rescheduling/reschedule.go
Original file line number Diff line number Diff line change
Expand Up @@ -563,15 +563,7 @@ func (reScheduler *ReScheduler) SynCacheFaultJobWithSession(ssn *framework.Sessi

jobInfo := faultJob.jobInfoInSession(ssn.Jobs)
if jobInfo == nil {
klog.V(util.LogDebugLev).Infof("faultJob name: %s not in session", faultJob.JobName)
if !faultJob.CheckJobExistsInKubernetes(ssn) { // 1.1 delete jobs not in session or k8s
klog.V(util.LogWarningLev).Infof(
"delete %s from re-scheduler cache due to not existence in session and k8s.", faultJob.JobName)
continue
}
faultJob.UpdateTime = nowTime
faultJob.IsInSession = false
updatedFaultJobs = append(updatedFaultJobs, faultJob) // 1.2 keep jobs not in session but in k8s
klog.V(util.LogWarningLev).Infof("faultJob name: %s not in session", faultJob.JobName)
continue
}
// 2. cache Jobs turned normal in session should be deleted ,meaning it has been restarted
Expand Down

0 comments on commit 27bdfa5

Please sign in to comment.