Repository: hadoop Updated Branches: refs/heads/branch-2.9 5b270b53b -> f116868a5
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/f116868a Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/f116868a Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/f116868a Branch: refs/heads/branch-2.9 Commit: f116868a530d92c4b8535b98c32fd42378ed84d7 Parents: 5b270b5 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 21:13:59 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/f116868a/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]
