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

MAPREDUCE-3801: org.apache.hadoop.mapreduce.v2.app.TestRuntimeEstimators.testExponentialEstimator fails intermittently. Contributed by Jason Lowe

Browse Source
This commit is contained in:
Eric E Payne 2018-09-18 20:26:28 +00:00
parent f938925bde
commit 2cf8927683
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/speculate/DefaultSpeculator.java
View File

@ -100,8 +100,6 @@ public class DefaultSpeculator extends AbstractService implements
private AppContext context; private AppContext context;
private Thread speculationBackgroundThread = null; private Thread speculationBackgroundThread = null;
private volatile boolean stopped = false; private volatile boolean stopped = false;
private BlockingQueue<SpeculatorEvent> eventQueue
= new LinkedBlockingQueue<SpeculatorEvent>();
private TaskRuntimeEstimator estimator; private TaskRuntimeEstimator estimator;
private BlockingQueue<Object> scanControl = new LinkedBlockingQueue<Object>(); private BlockingQueue<Object> scanControl = new LinkedBlockingQueue<Object>();
@ -247,7 +245,7 @@ public void handleAttempt(TaskAttemptStatus status) {
// This section is not part of the Speculator interface; it's used only for // This section is not part of the Speculator interface; it's used only for
// testing // testing
public boolean eventQueueEmpty() { public boolean eventQueueEmpty() {
return eventQueue.isEmpty(); return scanControl.isEmpty();
} }
// This interface is intended to be used only for test cases. // This interface is intended to be used only for test cases.