diff --git a/pkg/scheduler/internal/cache/cache.go b/pkg/scheduler/internal/cache/cache.go index 1cd69a9704d..c5715d12b18 100644 --- a/pkg/scheduler/internal/cache/cache.go +++ b/pkg/scheduler/internal/cache/cache.go @@ -750,7 +750,7 @@ func (cache *cacheImpl) cleanupAssumedPods(now time.Time) { "pod", klog.KObj(ps.pod)) continue } - if now.After(*ps.deadline) { + if cache.ttl != 0 && now.After(*ps.deadline) { klog.InfoS("Pod expired", "pod", klog.KObj(ps.pod)) if err := cache.removePod(ps.pod); err != nil { klog.ErrorS(err, "ExpirePod failed", "pod", klog.KObj(ps.pod)) diff --git a/pkg/scheduler/scheduler.go b/pkg/scheduler/scheduler.go index c165b34ffc2..1635c381fd1 100644 --- a/pkg/scheduler/scheduler.go +++ b/pkg/scheduler/scheduler.go @@ -53,7 +53,7 @@ import ( const ( // Duration the scheduler will wait before expiring an assumed pod. // See issue #106361 for more details about this parameter and its value. - durationToExpireAssumedPod = 15 * time.Minute + durationToExpireAssumedPod = 0 * time.Minute ) // ErrNoNodesAvailable is used to describe the error that no nodes available to schedule pods.