|
@@ -4512,7 +4512,7 @@ public class TestFairScheduler extends FairSchedulerTestBase {
|
|
scheduler.handle(new NodeUpdateSchedulerEvent(node2));
|
|
scheduler.handle(new NodeUpdateSchedulerEvent(node2));
|
|
|
|
|
|
assertEquals(4096, scheduler.getQueueManager().getQueue("queue1").
|
|
assertEquals(4096, scheduler.getQueueManager().getQueue("queue1").
|
|
- getResourceUsage().getMemory());
|
|
|
|
|
|
+ getResourceUsage().getMemorySize());
|
|
|
|
|
|
//container will be reserved at node1
|
|
//container will be reserved at node1
|
|
RMContainer reservedContainer1 =
|
|
RMContainer reservedContainer1 =
|
|
@@ -4532,7 +4532,7 @@ public class TestFairScheduler extends FairSchedulerTestBase {
|
|
app1, RMAppAttemptState.KILLED, false));
|
|
app1, RMAppAttemptState.KILLED, false));
|
|
|
|
|
|
assertEquals(0, scheduler.getQueueManager().getQueue("queue1").
|
|
assertEquals(0, scheduler.getQueueManager().getQueue("queue1").
|
|
- getResourceUsage().getMemory());
|
|
|
|
|
|
+ getResourceUsage().getMemorySize());
|
|
|
|
|
|
// container will be allocated at node2
|
|
// container will be allocated at node2
|
|
scheduler.handle(new NodeUpdateSchedulerEvent(node2));
|
|
scheduler.handle(new NodeUpdateSchedulerEvent(node2));
|