|
@@ -1527,7 +1527,7 @@ public class TestCapacityScheduler {
|
|
|
String queue =
|
|
|
scheduler.getApplicationAttempt(appsInA1.get(0)).getQueue()
|
|
|
.getQueueName();
|
|
|
- Assert.assertTrue(queue.equals("a1"));
|
|
|
+ Assert.assertEquals("a1", queue);
|
|
|
|
|
|
List<ApplicationAttemptId> appsInA = scheduler.getAppsInQueue("a");
|
|
|
assertTrue(appsInA.contains(appAttemptId));
|
|
@@ -1552,7 +1552,7 @@ public class TestCapacityScheduler {
|
|
|
queue =
|
|
|
scheduler.getApplicationAttempt(appsInB1.get(0)).getQueue()
|
|
|
.getQueueName();
|
|
|
- Assert.assertTrue(queue.equals("b1"));
|
|
|
+ Assert.assertEquals("b1", queue);
|
|
|
|
|
|
appsInB = scheduler.getAppsInQueue("b");
|
|
|
assertTrue(appsInB.contains(appAttemptId));
|
|
@@ -1589,7 +1589,7 @@ public class TestCapacityScheduler {
|
|
|
String queue =
|
|
|
scheduler.getApplicationAttempt(appsInA1.get(0)).getQueue()
|
|
|
.getQueueName();
|
|
|
- Assert.assertTrue(queue.equals("a1"));
|
|
|
+ Assert.assertEquals("a1", queue);
|
|
|
|
|
|
List<ApplicationAttemptId> appsInA = scheduler.getAppsInQueue("a");
|
|
|
assertTrue(appsInA.contains(appAttemptId));
|
|
@@ -1611,7 +1611,7 @@ public class TestCapacityScheduler {
|
|
|
queue =
|
|
|
scheduler.getApplicationAttempt(appsInA2.get(0)).getQueue()
|
|
|
.getQueueName();
|
|
|
- Assert.assertTrue(queue.equals("a2"));
|
|
|
+ Assert.assertEquals("a2", queue);
|
|
|
|
|
|
appsInA1 = scheduler.getAppsInQueue("a1");
|
|
|
assertTrue(appsInA1.isEmpty());
|
|
@@ -2109,7 +2109,7 @@ public class TestCapacityScheduler {
|
|
|
String queue =
|
|
|
scheduler.getApplicationAttempt(appsInA1.get(0)).getQueue()
|
|
|
.getQueueName();
|
|
|
- Assert.assertTrue(queue.equals("a1"));
|
|
|
+ Assert.assertEquals("a1", queue);
|
|
|
|
|
|
List<ApplicationAttemptId> appsInRoot = scheduler.getAppsInQueue("root");
|
|
|
assertTrue(appsInRoot.contains(appAttemptId));
|
|
@@ -2131,7 +2131,7 @@ public class TestCapacityScheduler {
|
|
|
queue =
|
|
|
scheduler.getApplicationAttempt(appsInB1.get(0)).getQueue()
|
|
|
.getQueueName();
|
|
|
- Assert.assertTrue(queue.equals("b1"));
|
|
|
+ Assert.assertEquals("b1", queue);
|
|
|
|
|
|
appsInB = scheduler.getAppsInQueue("b");
|
|
|
assertTrue(appsInB.contains(appAttemptId));
|
|
@@ -2487,7 +2487,7 @@ public class TestCapacityScheduler {
|
|
|
String queue =
|
|
|
scheduler.getApplicationAttempt(appsInA1.get(0)).getQueue()
|
|
|
.getQueueName();
|
|
|
- Assert.assertTrue(queue.equals("a1"));
|
|
|
+ Assert.assertEquals("a1", queue);
|
|
|
|
|
|
List<ApplicationAttemptId> appsInRoot = scheduler.getAppsInQueue("root");
|
|
|
assertTrue(appsInRoot.contains(appAttemptId));
|