Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-1880. Cleanup TestApplicationClientProtocolOnHA. Contributed by ozawa.

This commit is contained in:
Harsh J 2015-03-24 11:57:28 +05:30
parent 970ee3fc56
commit fbceb3b418
2 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-yarn-project/CHANGES.txt
View File

@ -58,6 +58,9 @@ Release 2.8.0 - UNRELEASED
IMPROVEMENTS IMPROVEMENTS
YARN-1880. Cleanup TestApplicationClientProtocolOnHA
(ozawa via harsh)
YARN-3243. CapacityScheduler should pass headroom from parent to children YARN-3243. CapacityScheduler should pass headroom from parent to children
to make sure ParentQueue obey its capacity limits. (Wangda Tan via jianhe) to make sure ParentQueue obey its capacity limits. (Wangda Tan via jianhe)

16
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/TestApplicationClientProtocolOnHA.java
View File

@ -93,7 +93,8 @@ public class TestApplicationClientProtocolOnHA extends ProtocolHATestBase {
public void testGetApplicationsOnHA() throws Exception { public void testGetApplicationsOnHA() throws Exception {
List<ApplicationReport> reports = List<ApplicationReport> reports =
client.getApplications(); client.getApplications();
Assert.assertTrue(reports != null && !reports.isEmpty()); Assert.assertTrue(reports != null);
Assert.assertFalse(reports.isEmpty());
Assert.assertEquals(cluster.createFakeAppReports(), Assert.assertEquals(cluster.createFakeAppReports(),
reports); reports);
} }
@ -101,7 +102,8 @@ public class TestApplicationClientProtocolOnHA extends ProtocolHATestBase {
@Test(timeout = 15000) @Test(timeout = 15000)
public void testGetClusterNodesOnHA() throws Exception { public void testGetClusterNodesOnHA() throws Exception {
List<NodeReport> reports = client.getNodeReports(NodeState.RUNNING); List<NodeReport> reports = client.getNodeReports(NodeState.RUNNING);
Assert.assertTrue(reports != null && !reports.isEmpty()); Assert.assertTrue(reports != null);
Assert.assertFalse(reports.isEmpty());
Assert.assertEquals(cluster.createFakeNodeReports(), Assert.assertEquals(cluster.createFakeNodeReports(),
reports); reports);
} }
@ -117,8 +119,8 @@ public class TestApplicationClientProtocolOnHA extends ProtocolHATestBase {
@Test(timeout = 15000) @Test(timeout = 15000)
public void testGetQueueUserAclsOnHA() throws Exception { public void testGetQueueUserAclsOnHA() throws Exception {
List<QueueUserACLInfo> queueUserAclsList = client.getQueueAclsInfo(); List<QueueUserACLInfo> queueUserAclsList = client.getQueueAclsInfo();
Assert.assertTrue(queueUserAclsList != null Assert.assertTrue(queueUserAclsList != null);
&& !queueUserAclsList.isEmpty()); Assert.assertFalse(queueUserAclsList.isEmpty());
Assert.assertEquals(cluster.createFakeQueueUserACLInfoList(), Assert.assertEquals(cluster.createFakeQueueUserACLInfoList(),
queueUserAclsList); queueUserAclsList);
} }
@ -136,7 +138,8 @@ public class TestApplicationClientProtocolOnHA extends ProtocolHATestBase {
public void testGetApplicationAttemptsOnHA() throws Exception { public void testGetApplicationAttemptsOnHA() throws Exception {
List<ApplicationAttemptReport> reports = List<ApplicationAttemptReport> reports =
client.getApplicationAttempts(cluster.createFakeAppId()); client.getApplicationAttempts(cluster.createFakeAppId());
Assert.assertTrue(reports != null && !reports.isEmpty()); Assert.assertTrue(reports != null);
Assert.assertFalse(reports.isEmpty());
Assert.assertEquals(cluster.createFakeApplicationAttemptReports(), Assert.assertEquals(cluster.createFakeApplicationAttemptReports(),
reports); reports);
} }
@ -153,7 +156,8 @@ public class TestApplicationClientProtocolOnHA extends ProtocolHATestBase {
public void testGetContainersOnHA() throws Exception { public void testGetContainersOnHA() throws Exception {
List<ContainerReport> reports = List<ContainerReport> reports =
client.getContainers(cluster.createFakeApplicationAttemptId()); client.getContainers(cluster.createFakeApplicationAttemptId());
Assert.assertTrue(reports != null && !reports.isEmpty()); Assert.assertTrue(reports != null);
Assert.assertFalse(reports.isEmpty());
Assert.assertEquals(cluster.createFakeContainerReports(), Assert.assertEquals(cluster.createFakeContainerReports(),
reports); reports);
} }