hadoop git commit: MAPREDUCE-6675. TestJobImpl.testUnusableNode failed (haibochen via rkanter) (cherry picked from commit 9d3fcdfbb314c83ba6185e4ac8de649dad51a279)

[epayne]

Repository: hadoop
Updated Branches:
  refs/heads/branch-2.8 a631247c2 -> d738f4b65


MAPREDUCE-6675. TestJobImpl.testUnusableNode failed (haibochen via rkanter)
(cherry picked from commit 9d3fcdfbb314c83ba6185e4ac8de649dad51a279)


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/d738f4b6
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/d738f4b6
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/d738f4b6

Branch: refs/heads/branch-2.8
Commit: d738f4b6521acf04e0242859f6bd9522ea0a5b9c
Parents: a631247
Author: Robert Kanter 
Authored: Wed May 4 22:42:21 2016 -0700
Committer: Eric Payne 
Committed: Wed Jan 4 18:18:29 2017 +

--
 .../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/d738f4b6/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 97ec0c7..64d2c2b 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-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org

[11/50] [abbrv] hadoop git commit: MAPREDUCE-6675. TestJobImpl.testUnusableNode failed (haibochen via rkanter)

[wangda]

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/YARN-3368
Commit: 9d3fcdfbb314c83ba6185e4ac8de649dad51a279
Parents: ecce3b7
Author: Robert Kanter 
Authored: Wed May 4 22:42:21 2016 -0700
Committer: Robert Kanter 
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-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org

[26/50] [abbrv] hadoop git commit: MAPREDUCE-6675. TestJobImpl.testUnusableNode failed (haibochen via rkanter)

[aengineer]

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/HDFS-1312
Commit: 9d3fcdfbb314c83ba6185e4ac8de649dad51a279
Parents: ecce3b7
Author: Robert Kanter 
Authored: Wed May 4 22:42:21 2016 -0700
Committer: Robert Kanter 
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-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org

[02/28] hadoop git commit: MAPREDUCE-6675. TestJobImpl.testUnusableNode failed (haibochen via rkanter)

[aw]

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/HADOOP-12930
Commit: 9d3fcdfbb314c83ba6185e4ac8de649dad51a279
Parents: ecce3b7
Author: Robert Kanter 
Authored: Wed May 4 22:42:21 2016 -0700
Committer: Robert Kanter 
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-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org

hadoop git commit: MAPREDUCE-6675. TestJobImpl.testUnusableNode failed (haibochen via rkanter)

[rkanter]

Repository: hadoop
Updated Branches:
  refs/heads/branch-2 cca8e9b90 -> f9d609210


MAPREDUCE-6675. TestJobImpl.testUnusableNode failed (haibochen via rkanter)

(cherry picked from commit 9d3fcdfbb314c83ba6185e4ac8de649dad51a279)


Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/f9d60921
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/f9d60921
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/f9d60921

Branch: refs/heads/branch-2
Commit: f9d60921083d38efcd77a47748d6975eefbaab29
Parents: cca8e9b
Author: Robert Kanter 
Authored: Wed May 4 22:42:21 2016 -0700
Committer: Robert Kanter 
Committed: Wed May 4 22:42:34 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/f9d60921/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-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org

hadoop git commit: MAPREDUCE-6675. TestJobImpl.testUnusableNode failed (haibochen via rkanter)

[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 
Authored: Wed May 4 22:42:21 2016 -0700
Committer: Robert Kanter 
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-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org