diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index e17a794..d53397a 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -287,9 +287,10 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task) NodeStatus { } } - for i, lock := range locks { + for i, _ := range locks { log.Info("unlock ", i) - lock.Unlock() + //lock.Unlock() + pool.poolsMu[i].Unlock() } go func(res NodeStatus) { if len(res.Status) == 0 {