diff --git a/worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/BufferStatusHub.java b/worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/BufferStatusHub.java
index 14a0dfd5a..88c42bb52 100644
--- a/worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/BufferStatusHub.java
+++ b/worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/BufferStatusHub.java
@@ -78,7 +78,7 @@ public class BufferStatusHub extends TimeSlidingHub<BufferStatusHub.BufferStatus
     Pair<BufferStatusNode, Integer> sumInfo = sum();
     long currentNumBytes = sumInfo.getKey().numBytes();
     if (currentNumBytes > 0) {
-      return currentNumBytes * 1000 / (long) sumInfo.getRight() * intervalPerBucketInMills;
+      return currentNumBytes * 1000 / ((long) sumInfo.getRight() * intervalPerBucketInMills);
     }
     return 0L;
   }