diff --git a/internal/scheduler/scheduling/scheduling_algo.go b/internal/scheduler/scheduling/scheduling_algo.go index d5bc943a3bd..535fbe3056b 100644 --- a/internal/scheduler/scheduling/scheduling_algo.go +++ b/internal/scheduler/scheduling/scheduling_algo.go @@ -275,7 +275,9 @@ func (l *FairSchedulingAlgo) getCapacityForPool(pool string, executors []*schedu totalCapacity := schedulerobjects.ResourceList{} for _, executor := range executors { for _, node := range executor.Nodes { - totalCapacity.Add(node.TotalResources) + if node.Pool == pool { + totalCapacity.Add(node.TotalResources) + } } } totalCapacity.Add(l.floatingResourceTypes.GetTotalAvailableForPool(pool))