diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 1573e20..c2efbfa 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -310,7 +310,7 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task) NodeStatus { } func (scheduler *SchedulerFair) ReleaseResource(job Job, agent NodeStatus) { - poolID := rand.Intn(pool.poolsCount) + poolID := pool.getNodePool(agent.ClientID) pool.poolsMu[poolID].Lock() defer pool.poolsMu[poolID].Unlock()