Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDFS-9772. TestBlockReplacement#testThrottler doesn't work as expected. Contributed by Lin Yiqun. 

(cherry picked from commit 903428bf94)
This commit is contained in:
Walter Su 2016-04-13 17:49:45 +08:00
parent 59b0661c7f
commit f3dbabb13a
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/datanode/TestBlockReplacement.java
View File

@ -81,7 +81,6 @@ public class TestBlockReplacement {
long bytesToSend = TOTAL_BYTES; long bytesToSend = TOTAL_BYTES;
long start = Time.monotonicNow(); long start = Time.monotonicNow();
DataTransferThrottler throttler = new DataTransferThrottler(bandwidthPerSec); DataTransferThrottler throttler = new DataTransferThrottler(bandwidthPerSec);
long totalBytes = 0L;
long bytesSent = 1024*512L; // 0.5MB long bytesSent = 1024*512L; // 0.5MB
throttler.throttle(bytesSent); throttler.throttle(bytesSent);
bytesToSend -= bytesSent; bytesToSend -= bytesSent;
@ -93,7 +92,7 @@ public class TestBlockReplacement {
} catch (InterruptedException ignored) {} } catch (InterruptedException ignored) {}
throttler.throttle(bytesToSend); throttler.throttle(bytesToSend);
long end = Time.monotonicNow(); long end = Time.monotonicNow();
assertTrue(totalBytes*1000/(end-start)<=bandwidthPerSec); assertTrue(TOTAL_BYTES * 1000 / (end - start) <= bandwidthPerSec);
} }
@Test @Test