Merge r1611240 from trunk. Addendum patch for YARN-2219
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-2@1611241 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
af13d4e18c
commit
ad43e5bd1a
|
@ -228,7 +228,7 @@ public class TestFifoScheduler {
|
|||
scheduler.handle(new NodeAddedSchedulerEvent(node));
|
||||
|
||||
ApplicationId appId = ApplicationId.newInstance(0, 1);
|
||||
scheduler.addApplication(appId, "queue1", "user1", true);
|
||||
scheduler.addApplication(appId, "queue1", "user1", false);
|
||||
|
||||
NodeUpdateSchedulerEvent updateEvent = new NodeUpdateSchedulerEvent(node);
|
||||
try {
|
||||
|
@ -238,7 +238,7 @@ public class TestFifoScheduler {
|
|||
}
|
||||
|
||||
ApplicationAttemptId attId = ApplicationAttemptId.newInstance(appId, 1);
|
||||
scheduler.addApplicationAttempt(attId, false, true);
|
||||
scheduler.addApplicationAttempt(attId, false, false);
|
||||
|
||||
rm.stop();
|
||||
}
|
||||
|
|
|
@ -147,11 +147,11 @@ public class FairSchedulerTestBase {
|
|||
int memory, int vcores, String queueId, String userId, int numContainers,
|
||||
int priority) {
|
||||
ApplicationAttemptId id = createAppAttemptId(this.APP_ID++, this.ATTEMPT_ID++);
|
||||
scheduler.addApplication(id.getApplicationId(), queueId, userId, true);
|
||||
scheduler.addApplication(id.getApplicationId(), queueId, userId, false);
|
||||
// This conditional is for testAclSubmitApplication where app is rejected
|
||||
// and no app is added.
|
||||
if (scheduler.getSchedulerApplications().containsKey(id.getApplicationId())) {
|
||||
scheduler.addApplicationAttempt(id, false, true);
|
||||
scheduler.addApplicationAttempt(id, false, false);
|
||||
}
|
||||
List<ResourceRequest> ask = new ArrayList<ResourceRequest>();
|
||||
ResourceRequest request = createResourceRequest(memory, vcores, ResourceRequest.ANY,
|
||||
|
@ -172,11 +172,11 @@ public class FairSchedulerTestBase {
|
|||
String userId, List<ResourceRequest> ask) {
|
||||
ApplicationAttemptId id = createAppAttemptId(this.APP_ID++,
|
||||
this.ATTEMPT_ID++);
|
||||
scheduler.addApplication(id.getApplicationId(), queueId, userId);
|
||||
scheduler.addApplication(id.getApplicationId(), queueId, userId, false);
|
||||
// This conditional is for testAclSubmitApplication where app is rejected
|
||||
// and no app is added.
|
||||
if (scheduler.getSchedulerApplications().containsKey(id.getApplicationId())) {
|
||||
scheduler.addApplicationAttempt(id, false, true);
|
||||
scheduler.addApplicationAttempt(id, false, false);
|
||||
}
|
||||
scheduler.allocate(id, ask, new ArrayList<ContainerId>(), null, null);
|
||||
RMApp rmApp = mock(RMApp.class);
|
||||
|
|
|
@ -793,14 +793,14 @@ public class TestFairScheduler extends FairSchedulerTestBase {
|
|||
scheduler.reinitialize(conf, resourceManager.getRMContext());
|
||||
|
||||
ApplicationAttemptId id11 = createAppAttemptId(1, 1);
|
||||
scheduler.addApplication(id11.getApplicationId(), "root.queue1", "user1", true);
|
||||
scheduler.addApplicationAttempt(id11, false, true);
|
||||
scheduler.addApplication(id11.getApplicationId(), "root.queue1", "user1", false);
|
||||
scheduler.addApplicationAttempt(id11, false, false);
|
||||
ApplicationAttemptId id21 = createAppAttemptId(2, 1);
|
||||
scheduler.addApplication(id21.getApplicationId(), "root.queue2", "user1", true);
|
||||
scheduler.addApplicationAttempt(id21, false, true);
|
||||
scheduler.addApplication(id21.getApplicationId(), "root.queue2", "user1", false);
|
||||
scheduler.addApplicationAttempt(id21, false, false);
|
||||
ApplicationAttemptId id22 = createAppAttemptId(2, 2);
|
||||
scheduler.addApplication(id22.getApplicationId(), "root.queue2", "user1", true);
|
||||
scheduler.addApplicationAttempt(id22, false, true);
|
||||
scheduler.addApplication(id22.getApplicationId(), "root.queue2", "user1", false);
|
||||
scheduler.addApplicationAttempt(id22, false, false);
|
||||
|
||||
int minReqSize =
|
||||
FairSchedulerConfiguration.DEFAULT_RM_SCHEDULER_INCREMENT_ALLOCATION_MB;
|
||||
|
@ -1561,8 +1561,8 @@ public class TestFairScheduler extends FairSchedulerTestBase {
|
|||
scheduler.handle(nodeEvent2);
|
||||
|
||||
ApplicationAttemptId appId = createAppAttemptId(this.APP_ID++, this.ATTEMPT_ID++);
|
||||
scheduler.addApplication(appId.getApplicationId(), "queue1", "user1", true);
|
||||
scheduler.addApplicationAttempt(appId, false, true);
|
||||
scheduler.addApplication(appId.getApplicationId(), "queue1", "user1", false);
|
||||
scheduler.addApplicationAttempt(appId, false, false);
|
||||
|
||||
// 1 request with 2 nodes on the same rack. another request with 1 node on
|
||||
// a different rack
|
||||
|
@ -1843,7 +1843,7 @@ public class TestFairScheduler extends FairSchedulerTestBase {
|
|||
|
||||
ApplicationAttemptId attId =
|
||||
ApplicationAttemptId.newInstance(applicationId, this.ATTEMPT_ID++);
|
||||
scheduler.addApplication(attId.getApplicationId(), queue, user, true);
|
||||
scheduler.addApplication(attId.getApplicationId(), queue, user, false);
|
||||
|
||||
numTries = 0;
|
||||
while (application.getFinishTime() == 0 && numTries < MAX_TRIES) {
|
||||
|
@ -2720,8 +2720,8 @@ public class TestFairScheduler extends FairSchedulerTestBase {
|
|||
// send application request
|
||||
ApplicationAttemptId appAttemptId =
|
||||
createAppAttemptId(this.APP_ID++, this.ATTEMPT_ID++);
|
||||
fs.addApplication(appAttemptId.getApplicationId(), "queue11", "user11", true);
|
||||
fs.addApplicationAttempt(appAttemptId, false, true);
|
||||
fs.addApplication(appAttemptId.getApplicationId(), "queue11", "user11", false);
|
||||
fs.addApplicationAttempt(appAttemptId, false, false);
|
||||
List<ResourceRequest> ask = new ArrayList<ResourceRequest>();
|
||||
ResourceRequest request =
|
||||
createResourceRequest(1024, 1, ResourceRequest.ANY, 1, 1, true);
|
||||
|
|
Loading…
Reference in New Issue