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

YARN-7918. Fix TestAMRMClientPlacementConstraints. (Gergely Novák via asuresh)

This commit is contained in:
Arun Suresh 2018-02-17 03:24:55 -08:00
parent 31db977cb3
commit a1e56a6286
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/constraint/processor/PlacementConstraintProcessor.java
View File

@ -17,6 +17,7 @@
*/ */
package org.apache.hadoop.yarn.server.resourcemanager.scheduler.constraint.processor; package org.apache.hadoop.yarn.server.resourcemanager.scheduler.constraint.processor;
import com.google.common.collect.Lists;
import org.apache.hadoop.yarn.ams.ApplicationMasterServiceContext; import org.apache.hadoop.yarn.ams.ApplicationMasterServiceContext;
import org.apache.hadoop.yarn.ams.ApplicationMasterServiceProcessor; import org.apache.hadoop.yarn.ams.ApplicationMasterServiceProcessor;
import org.apache.hadoop.yarn.ams.ApplicationMasterServiceUtils; import org.apache.hadoop.yarn.ams.ApplicationMasterServiceUtils;
@ -329,7 +330,7 @@ public class PlacementConstraintProcessor extends AbstractPlacementProcessor {
if (!isAdded) { if (!isAdded) {
BatchedRequests br = new BatchedRequests(iteratorType, BatchedRequests br = new BatchedRequests(iteratorType,
schedulerResponse.getApplicationId(), schedulerResponse.getApplicationId(),
Collections.singleton(schedulerResponse.getSchedulingRequest()), Lists.newArrayList(schedulerResponse.getSchedulingRequest()),
placementAttempt + 1); placementAttempt + 1);
reqsToRetry.add(br); reqsToRetry.add(br);
br.addToBlacklist( br.addToBlacklist(