From cb9f752baf1047323505911f4267352d0ac58c31 Mon Sep 17 00:00:00 2001
From: Newnius <newnius.cn@gmail.com>
Date: Thu, 30 Apr 2020 15:59:41 +0800
Subject: [PATCH] update

---
 src/scheduler_fair.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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()