big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

MAPREDUCE-6967. gridmix/SleepReducer should use Time.monotonicNow for measuring durations. Contributed by Chetna Chaudhari

Browse Source
This commit is contained in:
Jason Lowe 2017-09-22 15:21:42 -05:00
parent 08fca508e6
commit b133dc5700
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-tools/hadoop-gridmix/src/main/java/org/apache/hadoop/mapred/gridmix/SleepJob.java
View File

@ -52,6 +52,7 @@
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.util.Time;
public class SleepJob extends GridmixJob { public class SleepJob extends GridmixJob {
public static final Log LOG = LogFactory.getLog(SleepJob.class); public static final Log LOG = LogFactory.getLog(SleepJob.class);
@ -184,7 +185,7 @@ protected void setup(Context context)
TimeUnit.MILLISECONDS.convert(sleepInterval, TimeUnit.SECONDS); TimeUnit.MILLISECONDS.convert(sleepInterval, TimeUnit.SECONDS);
//This is to stop accumulating deviation from expected sleep time //This is to stop accumulating deviation from expected sleep time
//over a period of time. //over a period of time.
long start = System.currentTimeMillis(); long start = Time.monotonicNow();
long slept = 0L; long slept = 0L;
long sleep = 0L; long sleep = 0L;
while (slept < duration) { while (slept < duration) {
@ -192,7 +193,7 @@ protected void setup(Context context)
sleep = Math.min(rem, RINTERVAL); sleep = Math.min(rem, RINTERVAL);
context.setStatus("Sleeping... " + rem + " ms left"); context.setStatus("Sleeping... " + rem + " ms left");
TimeUnit.MILLISECONDS.sleep(sleep); TimeUnit.MILLISECONDS.sleep(sleep);
slept = System.currentTimeMillis() - start; slept = Time.monotonicNow() - start;
} }
} }