MAPREDUCE-3801: org.apache.hadoop.mapreduce.v2.app.TestRuntimeEstimators.testExponentialEstimator fails intermittently. Contributed by Jason Lowe
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/2cf89276 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/2cf89276 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/2cf89276 Branch: refs/heads/YARN-7402 Commit: 2cf8927683d49f4cdc3cba038480128c473c5461 Parents: f938925 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:26:28 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/2cf89276/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]
