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 12fbdad814..1d495c45b6 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 @@ -855,7 +855,7 @@ public int run(String[] args) throws IOException { long tStart = System.currentTimeMillis(); sequentialTest(fs, testType, nrBytes, nrFiles); long execTime = System.currentTimeMillis() - tStart; - String resultLine = "Seq Test exec time sec: " + (float)execTime / 1000; + String resultLine = "Seq Test exec time sec: " + msToSecs(execTime); LOG.info(resultLine); return 0; } @@ -919,6 +919,10 @@ static float toMB(long bytes) { return ((float)bytes)/MEGA; } + static float msToSecs(long timeMillis) { + return timeMillis / 1000.0f; + } + private boolean checkErasureCodePolicy(String erasureCodePolicyName, FileSystem fs, TestType testType) throws IOException { Collection list = @@ -1051,11 +1055,10 @@ else if (attr.endsWith(":sqrate")) " Date & time: " + new Date(System.currentTimeMillis()), " 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)), + " Throughput mb/sec: " + df.format(toMB(size) / msToSecs(time)), " Average IO rate mb/sec: " + df.format(med), " IO rate std deviation: " + df.format(stdDev), - " Test exec time sec: " + df.format((float)execTime / 1000), + " Test exec time sec: " + df.format(msToSecs(execTime)), "" }; PrintStream res = null;