From 4706dda5dae16fc925a64b4f3eefdf755cad8e8b Mon Sep 17 00:00:00 2001 From: Kapil Jain Date: Sat, 2 Jul 2022 13:31:22 +0530 Subject: [PATCH] Added code for disable scheduler cache expiry --- pkg/scheduler/internal/cache/cache.go | 2 +- pkg/scheduler/scheduler.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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.