MAPREDUCE-6966. DistSum 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/c71d1379 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/c71d1379 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/c71d1379 Branch: refs/heads/HDFS-7240 Commit: c71d13796039815350d3c73c51f9fe48531af0fa Parents: 53be075 Author: Akira Ajisaka <[email protected]> Authored: Fri Sep 22 15:07:59 2017 +0900 Committer: Akira Ajisaka <[email protected]> Committed: Fri Sep 22 15:07:59 2017 +0900 ---------------------------------------------------------------------- .../src/main/java/org/apache/hadoop/examples/pi/DistSum.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/c71d1379/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/pi/DistSum.java ---------------------------------------------------------------------- diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/pi/DistSum.java b/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/pi/DistSum.java index ffe63fe..9fb6665 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/pi/DistSum.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-examples/src/main/java/org/apache/hadoop/examples/pi/DistSum.java @@ -51,6 +51,7 @@ import org.apache.hadoop.mapreduce.TaskAttemptContext; import org.apache.hadoop.mapreduce.TaskInputOutputContext; import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat; import org.apache.hadoop.net.NetUtils; +import org.apache.hadoop.util.Time; import org.apache.hadoop.util.Tool; import org.apache.hadoop.util.ToolRunner; import org.slf4j.Logger; @@ -162,9 +163,9 @@ public final class DistSum extends Configured implements Tool { LOG.info(s = "sigma=" + sigma); context.setStatus(s); - final long start = System.currentTimeMillis(); + final long start = Time.monotonicNow(); sigma.compute(); - final long duration = System.currentTimeMillis() - start; + final long duration = Time.monotonicNow() - start; final TaskResult result = new TaskResult(sigma, duration); LOG.info(s = "result=" + result); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
