From b6c75b3ff73dfcdeebe1aa0e185dd8e7479fd236 Mon Sep 17 00:00:00 2001 From: Joseph Date: Tue, 27 Feb 2024 20:06:36 +0800 Subject: [PATCH] scheduler: fix reservation restricted options (#1926) Signed-off-by: Joseph --- pkg/scheduler/plugins/reservation/plugin.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/pkg/scheduler/plugins/reservation/plugin.go b/pkg/scheduler/plugins/reservation/plugin.go index 38284a7c2..92809f2ea 100644 --- a/pkg/scheduler/plugins/reservation/plugin.go +++ b/pkg/scheduler/plugins/reservation/plugin.go @@ -403,10 +403,11 @@ func (pl *Plugin) filterWithReservations(ctx context.Context, cycleState *framew allocated := rInfo.Allocated if len(preemptibleInRR) > 0 { allocated = quotav1.SubtractWithNonNegativeResult(allocated, preemptibleInRR) - allocated = quotav1.Mask(allocated, rInfo.ResourceNames) } + allocated = quotav1.Mask(allocated, rInfo.ResourceNames) rRemained := quotav1.SubtractWithNonNegativeResult(rInfo.Allocatable, allocated) - fits, _ := quotav1.LessThanOrEqual(state.podRequests, rRemained) + requests := quotav1.Mask(state.podRequests, rInfo.ResourceNames) + fits, _ := quotav1.LessThanOrEqual(requests, rRemained) if fits && nodeFits { hasSatisfiedReservation = true break