This is an automated email from the ASF dual-hosted git repository.
slfan1989 pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new f9f9aeefc6c HADOOP-19506. Fix TestThrottledInputStream when bandwidth
is equal to throttle limit (#7517) Contributed by Istvan Toth.
f9f9aeefc6c is described below
commit f9f9aeefc6c2efa430b7341b8003ef447041ef4c
Author: Istvan Toth <st...@apache.org>
AuthorDate: Wed Mar 19 02:16:44 2025 +0100
HADOOP-19506. Fix TestThrottledInputStream when bandwidth is equal to
throttle limit (#7517) Contributed by Istvan Toth.
Signed-off-by: Shilun Fan <slfan1...@apache.org>
---
.../java/org/apache/hadoop/tools/util/TestThrottledInputStream.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/hadoop-tools/hadoop-distcp/src/test/java/org/apache/hadoop/tools/util/TestThrottledInputStream.java
b/hadoop-tools/hadoop-distcp/src/test/java/org/apache/hadoop/tools/util/TestThrottledInputStream.java
index 758270938b9..dc6793e2d18 100644
---
a/hadoop-tools/hadoop-distcp/src/test/java/org/apache/hadoop/tools/util/TestThrottledInputStream.java
+++
b/hadoop-tools/hadoop-distcp/src/test/java/org/apache/hadoop/tools/util/TestThrottledInputStream.java
@@ -216,7 +216,7 @@ private void copyAndAssert(File tmpFile, File outFile, long
maxBPS)
assertEquals(in.getTotalBytesRead(), tmpFile.length());
long bytesPerSec = in.getBytesPerSec();
- assertTrue(bytesPerSec < maxBPS);
+ assertTrue(bytesPerSec <= maxBPS);
} finally {
IOUtils.closeStream(in);
IOUtils.closeStream(out);
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org
