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

MAPREDUCE-6964. BaileyBorweinPlouffe should use Time.monotonicNow for measuring durations. Contributed by Chetna Chaudhari 

(cherry picked from commit b9db0afa1e)
This commit is contained in:
Jason Lowe 2017-09-21 09:37:19 -05:00
parent 9bd1f364a7
commit 6c07077837
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/BaileyBorweinPlouffe.java
View File

@ -49,6 +49,7 @@ import org.apache.hadoop.mapreduce.RecordReader;
import org.apache.hadoop.mapreduce.Reducer; import org.apache.hadoop.mapreduce.Reducer;
import org.apache.hadoop.mapreduce.TaskAttemptContext; import org.apache.hadoop.mapreduce.TaskAttemptContext;
import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat; import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat;
import org.apache.hadoop.util.Time;
import org.apache.hadoop.util.Tool; import org.apache.hadoop.util.Tool;
import org.apache.hadoop.util.ToolRunner; import org.apache.hadoop.util.ToolRunner;
@ -379,7 +380,7 @@ public class BaileyBorweinPlouffe extends Configured implements Tool {
// start a map/reduce job // start a map/reduce job
out.println("\nStarting Job ..."); out.println("\nStarting Job ...");
final long startTime = System.currentTimeMillis(); final long startTime = Time.monotonicNow();
try { try {
if (!job.waitForCompletion(true)) { if (!job.waitForCompletion(true)) {
out.println("Job failed."); out.println("Job failed.");
@ -388,7 +389,7 @@ public class BaileyBorweinPlouffe extends Configured implements Tool {
} catch (Exception e) { } catch (Exception e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} finally { } finally {
final double duration = (System.currentTimeMillis() - startTime)/1000.0; final double duration = (Time.monotonicNow() - startTime)/1000.0;
out.println("Duration is " + duration + " seconds."); out.println("Duration is " + duration + " seconds.");
} }
out.println("Output file: " + hexfile); out.println("Output file: " + hexfile);