From 2f18cbcc7e65c4dcaf5d3cb3cdc211827c5f00d0 Mon Sep 17 00:00:00 2001 From: Haiyang Shi Date: Fri, 27 Jan 2017 16:18:12 -0500 Subject: [PATCH] Total Throughput Calculation Error in TestDFSIO Total throughput should be toMB(size) * 1000.0 / ((float) execTime) --- .../src/test/java/org/apache/hadoop/fs/TestDFSIO.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/fs/TestDFSIO.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/fs/TestDFSIO.java index d21816928061c..6c0426ae9b778 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/fs/TestDFSIO.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/fs/TestDFSIO.java @@ -1042,7 +1042,7 @@ else if (attr.endsWith(":sqrate")) " Number of files: " + tasks, " Total MBytes processed: " + df.format(toMB(size)), " Throughput mb/sec: " + df.format(size * 1000.0 / (time * MEGA)), - "Total Throughput mb/sec: " + df.format(toMB(size) / ((float)execTime)), + "Total Throughput mb/sec: " + df.format(toMB(size) * 1000.0 / ((float)execTime)), " Average IO rate mb/sec: " + df.format(med), " IO rate std deviation: " + df.format(stdDev), " Test exec time sec: " + df.format((float)execTime / 1000),