MAPREDUCE-6965. QuasiMonteCarlo should use Time.monotonicNow for measuring durations. Contributed by Chetna Chaudhari
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/908d8e91 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/908d8e91 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/908d8e91 Branch: refs/heads/HDFS-7240 Commit: 908d8e914ef55aca69cb8e725e62bda29d1073cc Parents: c71d137 Author: Jason Lowe <[email protected]> Authored: Fri Sep 22 09:34:53 2017 -0500 Committer: Jason Lowe <[email protected]> Committed: Fri Sep 22 09:34:53 2017 -0500 ---------------------------------------------------------------------- .../main/java/org/apache/hadoop/examples/QuasiMonteCarlo.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/908d8e91/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/QuasiMonteCarlo.java ---------------------------------------------------------------------- diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/QuasiMonteCarlo.java b/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/QuasiMonteCarlo.java index 3048fd3..25a25bf 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/QuasiMonteCarlo.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/QuasiMonteCarlo.java @@ -38,6 +38,7 @@ import org.apache.hadoop.mapreduce.lib.input.FileInputFormat; import org.apache.hadoop.mapreduce.lib.input.SequenceFileInputFormat; import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat; import org.apache.hadoop.mapreduce.lib.output.SequenceFileOutputFormat; +import org.apache.hadoop.util.Time; import org.apache.hadoop.util.Tool; import org.apache.hadoop.util.ToolRunner; @@ -302,13 +303,13 @@ public class QuasiMonteCarlo extends Configured implements Tool { //start a map/reduce job System.out.println("Starting Job"); - final long startTime = System.currentTimeMillis(); + final long startTime = Time.monotonicNow(); job.waitForCompletion(true); if (!job.isSuccessful()) { System.out.println("Job " + job.getJobID() + " failed!"); System.exit(1); } - final double duration = (System.currentTimeMillis() - startTime)/1000.0; + final double duration = (Time.monotonicNow() - startTime)/1000.0; System.out.println("Job Finished in " + duration + " seconds"); //read outputs --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
