You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by xk...@apache.org on 2018/09/20 20:30:22 UTC
[14/50] [abbrv] hadoop git commit: MAPREDUCE-3801:
org.apache.hadoop.mapreduce.v2.app.TestRuntimeEstimators.testExponentialEstimator
fails intermittently. Contributed by Jason Lowe
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/HDFS-12943
Commit: 2cf8927683d49f4cdc3cba038480128c473c5461
Parents: f938925
Author: Eric E Payne <er...@oath.com>
Authored: Tue Sep 18 20:26:28 2018 +0000
Committer: Eric E Payne <er...@oath.com>
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: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org