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 rk...@apache.org on 2016/05/05 05:42:30 UTC
hadoop git commit: MAPREDUCE-6675. TestJobImpl.testUnusableNode
failed (haibochen via rkanter)
Repository: hadoop
Updated Branches:
refs/heads/trunk ecce3b7d5 -> 9d3fcdfbb
MAPREDUCE-6675. TestJobImpl.testUnusableNode failed (haibochen via rkanter)
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/9d3fcdfb
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/9d3fcdfb
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/9d3fcdfb
Branch: refs/heads/trunk
Commit: 9d3fcdfbb314c83ba6185e4ac8de649dad51a279
Parents: ecce3b7
Author: Robert Kanter <rk...@apache.org>
Authored: Wed May 4 22:42:21 2016 -0700
Committer: Robert Kanter <rk...@apache.org>
Committed: Wed May 4 22:42:21 2016 -0700
----------------------------------------------------------------------
.../org/apache/hadoop/mapreduce/v2/app/job/impl/TestJobImpl.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/9d3fcdfb/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/job/impl/TestJobImpl.java
----------------------------------------------------------------------
diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/job/impl/TestJobImpl.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/job/impl/TestJobImpl.java
index fa0aef3..36221e0 100644
--- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/job/impl/TestJobImpl.java
+++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/job/impl/TestJobImpl.java
@@ -531,7 +531,7 @@ public class TestJobImpl {
Configuration conf = new Configuration();
conf.set(MRJobConfig.MR_AM_STAGING_DIR, stagingDir);
conf.setInt(MRJobConfig.NUM_REDUCES, 1);
- AsyncDispatcher dispatcher = new AsyncDispatcher();
+ DrainDispatcher dispatcher = new DrainDispatcher();
dispatcher.init(conf);
dispatcher.start();
CyclicBarrier syncBarrier = new CyclicBarrier(2);
@@ -608,6 +608,7 @@ public class TestJobImpl {
NodeReport secondMapperNodeReport = nodeReports.get(1);
job.handle(new JobUpdatedNodesEvent(job.getID(),
Collections.singletonList(firstMapperNodeReport)));
+ dispatcher.await();
// complete the reducer
for (TaskId taskId: job.tasks.keySet()) {
if (taskId.getTaskType() == TaskType.REDUCE) {
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org