From 73cbbb5509afed3599b109405f335e0bafb9280b Mon Sep 17 00:00:00 2001 From: Newnius Date: Mon, 4 May 2020 00:30:04 +0800 Subject: [PATCH] update --- src/scheduler_fair.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index d3ef829..2d63e6b 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -530,6 +530,9 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task, nodes []Node log.Info("Unlock ", segID) lock.Unlock() } + pool.pools[0].Lock.Lock() + pool.pools[0].Lock.Unlock() + log.Info("all locks released") go func(res NodeStatus) { if len(res.Status) == 0 {