Repository: hadoop Updated Branches: refs/heads/branch-2.8.2 82981738d -> 211c77a40
YARN-5349. TestWorkPreservingRMRestart#testUAMRecoveryOnRMWorkPreservingRestart fail intermittently. Contributed by Jason Lowe. (cherry picked from commit 8ce8672b6b551dacb9467924fc70f88790f5891f) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/211c77a4 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/211c77a4 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/211c77a4 Branch: refs/heads/branch-2.8.2 Commit: 211c77a40bbab3a7f06724e751a6642e1e4102c1 Parents: 8298173 Author: Eric Payne <[email protected]> Authored: Wed Aug 2 12:53:22 2017 -0500 Committer: Eric Payne <[email protected]> Committed: Wed Aug 2 13:20:47 2017 -0500 ---------------------------------------------------------------------- .../resourcemanager/TestWorkPreservingRMRestart.java | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/211c77a4/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestWorkPreservingRMRestart.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestWorkPreservingRMRestart.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestWorkPreservingRMRestart.java index 6307087..e9f90c5 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestWorkPreservingRMRestart.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/TestWorkPreservingRMRestart.java @@ -1329,11 +1329,11 @@ public class TestWorkPreservingRMRestart extends ParameterizedSchedulerTestBase nm1.nodeHeartbeat(true); List<Container> conts = am0.allocate(new ArrayList<ResourceRequest>(), new ArrayList<ContainerId>()).getAllocatedContainers(); - while (conts.size() == 0) { + while (conts.size() < 2) { nm1.nodeHeartbeat(true); conts.addAll(am0.allocate(new ArrayList<ResourceRequest>(), new ArrayList<ContainerId>()).getAllocatedContainers()); - Thread.sleep(500); + Thread.sleep(100); } // am failed,and relaunch it @@ -1433,14 +1433,12 @@ public class TestWorkPreservingRMRestart extends ParameterizedSchedulerTestBase nm1.nodeHeartbeat(true); List<Container> conts = am0.allocate(new ArrayList<ResourceRequest>(), new ArrayList<ContainerId>()).getAllocatedContainers(); - Assert.assertTrue(conts.isEmpty()); - while (conts.size() == 0) { + while (conts.size() < 2) { nm1.nodeHeartbeat(true); conts.addAll(am0.allocate(new ArrayList<ResourceRequest>(), new ArrayList<ContainerId>()).getAllocatedContainers()); - Thread.sleep(500); + Thread.sleep(100); } - Assert.assertFalse(conts.isEmpty()); // start new RM rm2 = new MockRM(conf, memStore); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
