From bac49853db71ed6dab22ea109ad334e098ff52eb Mon Sep 17 00:00:00 2001
From: Newnius <newnius.cn@gmail.com>
Date: Thu, 1 Aug 2019 14:07:51 +0800
Subject: [PATCH] update shceduler_fair

---
 src/scheduler_fair.go | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go
index c8e8893..1c401b7 100644
--- a/src/scheduler_fair.go
+++ b/src/scheduler_fair.go
@@ -340,10 +340,15 @@ func (scheduler *SchedulerFair) UpdateNextQueue() {
 		}
 	}
 
-	for k, v := range scheduler.resourceAllocations {
-		if t, ok := scheduler.queues[k]; !ok || len(t) == 0 {
+	for k, t := range scheduler.queues {
+		if len(t) == 0 {
 			continue
 		}
+		if _, ok := scheduler.resourceAllocations[k]; !ok {
+			scheduler.resourceAllocations[k] = &ResourceCount{}
+		}
+		v := scheduler.resourceAllocations[k]
+
 		tmp := 0.0
 		tmp += float64(v.CPU) / CPU
 		tmp += float64(v.Memory) / Memory