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

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

Browse Source 
(cherry picked from commit 2cf8927683d49f4cdc3cba038480128c473c5461)
This commit is contained in:
Eric E Payne 2018-09-18 20:26:28 +00:00
parent f6ab07e28c
commit 97a13eb046
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

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