diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
index 1f6ee873de5173..91ec701c5c1e70 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
@@ -1311,12 +1311,12 @@ private void computeScanRangeAssignmentByScheduler(
             if (!execHostPort.hostname.equals(minLocation.server.hostname) ||
                     execHostPort.port != minLocation.server.port) {
                 assignedBytesPerHost.put(minLocation.server,
-                        assignedBytesPerHost.get(minLocation.server) - scanRangeLength);
+                        assignedBytesPerHost.get(minLocation.server) - step);
                 Long id = assignedBytesPerHost.get(execHostPort);
                 if (id == null) {
                     assignedBytesPerHost.put(execHostPort, 0L);
                 } else {
-                    assignedBytesPerHost.put(execHostPort, id+scanRangeLength);
+                    assignedBytesPerHost.put(execHostPort, id + step);
                 }
             }
             this.addressToBackendID.put(execHostPort, backendIdRef.getRef());