From fd82855e8be21d42b034d4f343b0e5f24a86ff0c Mon Sep 17 00:00:00 2001 From: Angerszhuuuu Date: Mon, 10 Jul 2023 10:37:19 +0800 Subject: [PATCH] =?UTF-8?q?[CELEBORN-777][FOLLOWUP]=20CongestionControl=20?= =?UTF-8?q?getPotentialConsumeSpeed=20throw=20=E2=80=A6=20=20=20=E2=80=A6/?= =?UTF-8?q?zero=20error?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit ### What changes were proposed in this pull request? Fix compute bug ### Why are the changes needed? ### Does this PR introduce _any_ user-facing change? ### How was this patch tested? Closes #1693 from AngersZhuuuu/CELEBORN-777. Authored-by: Angerszhuuuu Signed-off-by: zky.zhoukeyong --- .../service/deploy/worker/congestcontrol/BufferStatusHub.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 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; }