Update PipeEndPointRateLimiter.java

apache · May 24, 2024 · 8484c92 · 8484c92
1 parent 22d2af1
commit 8484c92
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...rc/main/java/org/apache/iotdb/commons/pipe/connector/limiter/PipeEndPointRateLimiter.java b/...rc/main/java/org/apache/iotdb/commons/pipe/connector/limiter/PipeEndPointRateLimiter.java
@@ -25,9 +25,8 @@ public class PipeEndPointRateLimiter {
 
   private final RateLimiter rateLimiter = RateLimiter.create(Double.MAX_VALUE);
 
-  public PipeEndPointRateLimiter(double transferDataSizeBytesPerSecond) {
-    rateLimiter.setRate(
-        transferDataSizeBytesPerSecond <= 0 ? Double.MAX_VALUE : transferDataSizeBytesPerSecond);
+  public PipeEndPointRateLimiter(double bytesPerSecond) {
+    rateLimiter.setRate(bytesPerSecond <= 0 ? Double.MAX_VALUE : bytesPerSecond);
   }
 
   public void acquire(long bytes) {