Repository: hadoop Updated Branches: refs/heads/branch-3.0 61847f4ea -> 373c7a0ce
MAPREDUCE-3801: org.apache.hadoop.mapreduce.v2.app.TestRuntimeEstimators.testExponentialEstimator fails intermittently. Contributed by Jason Lowe (cherry picked from commit 2cf8927683d49f4cdc3cba038480128c473c5461) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/373c7a0c Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/373c7a0c Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/373c7a0c Branch: refs/heads/branch-3.0 Commit: 373c7a0ceb019e148f7e68597a8083ba93c0d010 Parents: 61847f4 Author: Eric E Payne <[email protected]> Authored: Tue Sep 18 20:26:28 2018 +0000 Committer: Eric E Payne <[email protected]> Committed: Tue Sep 18 20:42:35 2018 +0000 ---------------------------------------------------------------------- .../hadoop/mapreduce/v2/app/speculate/DefaultSpeculator.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/373c7a0c/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/speculate/DefaultSpeculator.java ---------------------------------------------------------------------- diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/speculate/DefaultSpeculator.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/speculate/DefaultSpeculator.java index fa65383..6573687 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/speculate/DefaultSpeculator.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/speculate/DefaultSpeculator.java @@ -100,8 +100,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>(); @@ -247,7 +245,7 @@ public class DefaultSpeculator extends AbstractService implements // 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. --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
