diff --git a/master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java b/master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java index 12330ce7d..715335881 100644 --- a/master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java +++ b/master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java @@ -224,7 +224,7 @@ public class SlotsAllocator { int nextSlaveInd = (nextMasterInd + 1) % workers.size(); if (restrictions != null) { while (!haveUsableSlots(restrictions, workers, nextSlaveInd) - || !satisfyRackAware(shouldRackAware, workers, masterIndex, nextSlaveInd)) { + || !satisfyRackAware(shouldRackAware, workers, nextMasterInd, nextSlaveInd)) { nextSlaveInd = (nextSlaveInd + 1) % workers.size(); if (nextSlaveInd == nextMasterInd) { break outer; @@ -233,7 +233,7 @@ public class SlotsAllocator { storageInfo = getStorageInfo(workers, nextSlaveInd, restrictions, workerDiskIndexForSlave); } else if (shouldRackAware) { - while (!satisfyRackAware(true, workers, masterIndex, nextSlaveInd)) { + while (!satisfyRackAware(true, workers, nextMasterInd, nextSlaveInd)) { nextSlaveInd = (nextSlaveInd + 1) % workers.size(); if (nextSlaveInd == nextMasterInd) { break outer;