Repository: hadoop Updated Branches: refs/heads/branch-2 f6ab07e28 -> 97a13eb04
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/97a13eb0 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/97a13eb0 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/97a13eb0 Branch: refs/heads/branch-2 Commit: 97a13eb046733cf28b10cca347996c44558a555a Parents: f6ab07e 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:54:07 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/97a13eb0/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 07a49af..c6bc441 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 @@ -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 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]
