File tree 1 file changed +4
-2
lines changed
1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -52,6 +52,8 @@ object Benchmark {
52
52
b.saveAsTextFile(outputTempPath)
53
53
}
54
54
55
+ log.info(" \n ABenchmark: Pass " + i " Aggregate Throughput : " + (nFiles * fSize.toLong)/ (timeW/ 1000 .toFloat) + " Bytes per second" )
56
+
55
57
totalTimeW += timeW
56
58
57
59
fs.delete(new Path (outputTempPath), true )
@@ -61,9 +63,9 @@ object Benchmark {
61
63
// make sure dir is empty
62
64
fs.delete(new Path (outputTempPath), true )
63
65
64
- log.info(" \n Benchmark: Total volume : " + (repeat * nFiles.toLong * fSize) + " Bytes" )
66
+ log.info(" \n\ n Benchmark: Total volume : " + (repeat * nFiles.toLong * fSize) + " Bytes" )
65
67
log.info(" \n Benchmark: Total write time : " + (totalTimeW/ 1000 .toFloat) + " s" )
66
- log.info(" \n ABenchmark: Aggregate Throughput : " + (repeat * nFiles * fSize.toLong)/ (totalTimeW/ 1000 .toFloat) + " Bytes per second" )
68
+ log.info(" \n ABenchmark: Aggregate Throughput : " + (repeat * nFiles * fSize.toLong)/ (totalTimeW/ 1000 .toFloat) + " Bytes per second\n " )
67
69
68
70
}
69
71
}
You can’t perform that action at this time.
0 commit comments