diff --git a/src/scheduler_fair.go b/src/scheduler_fair.go index 32b44e0..009a7b1 100644 --- a/src/scheduler_fair.go +++ b/src/scheduler_fair.go @@ -520,7 +520,8 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task, nodes []Node log.Info("allocatingGPU is ", scheduler.allocatingGPU) } - for _, lock := range locks { + for segID, lock := range locks { + log.Info("Unlock ", segID) lock.Unlock() }