|
@@ -126,7 +126,9 @@ public abstract class AbstractContainerAllocator {
|
|
LOG.info("assignedContainer" + " application attempt=" + application
|
|
LOG.info("assignedContainer" + " application attempt=" + application
|
|
.getApplicationAttemptId() + " container=" + updatedContainer
|
|
.getApplicationAttemptId() + " container=" + updatedContainer
|
|
.getContainerId() + " queue=" + this + " clusterResource="
|
|
.getContainerId() + " queue=" + this + " clusterResource="
|
|
- + clusterResource + " type=" + assignment.getType());
|
|
|
|
|
|
+ + clusterResource + " type=" + assignment.getType()
|
|
|
|
+ + " requestedPartition="
|
|
|
|
+ + updatedContainer.getNodeLabelExpression());
|
|
|
|
|
|
assignment.getAssignmentInformation().addAllocationDetails(
|
|
assignment.getAssignmentInformation().addAllocationDetails(
|
|
updatedContainer, application.getCSLeafQueue().getQueuePath());
|
|
updatedContainer, application.getCSLeafQueue().getQueuePath());
|
|
@@ -183,4 +185,4 @@ public abstract class AbstractContainerAllocator {
|
|
public abstract CSAssignment assignContainers(Resource clusterResource,
|
|
public abstract CSAssignment assignContainers(Resource clusterResource,
|
|
PlacementSet<FiCaSchedulerNode> ps, SchedulingMode schedulingMode,
|
|
PlacementSet<FiCaSchedulerNode> ps, SchedulingMode schedulingMode,
|
|
ResourceLimits resourceLimits, RMContainer reservedContainer);
|
|
ResourceLimits resourceLimits, RMContainer reservedContainer);
|
|
-}
|
|
|
|
|
|
+}
|