LongGang Chen created YARN-8354:
-----------------------------------
Summary: SingleConstraintAppPlacementAllocator's allocate does not
decPendingResource
Key: YARN-8354
URL: https://issues.apache.org/jira/browse/YARN-8354
Project: Hadoop YARN
Issue Type: Bug
Reporter: LongGang Chen
SingleConstraintAppPlacementAllocator.allocate() does not
decPendingResource,only
reduce ResourceSizing.numAllocations by one.
may be we should change
decreasePendingNumAllocation() form :
{code:java}
private void decreasePendingNumAllocation() {
// Deduct pending #allocations by 1
ResourceSizing sizing = schedulingRequest.getResourceSizing();
sizing.setNumAllocations(sizing.getNumAllocations() - 1);
}
{code}
to:
{code:java}
private void decreasePendingNumAllocation() {
// Deduct pending #allocations by 1
ResourceSizing sizing = schedulingRequest.getResourceSizing();
sizing.setNumAllocations(sizing.getNumAllocations() - 1);
// Deduct pending resource of app and queue
if (getExecutionType() == ExecutionType.OPPORTUNISTIC) {
appSchedulingInfo.decOpportunisticPendingResource(
schedulingRequest.getNodeLabelExpression(),
sizing.getResources());
}else{
appSchedulingInfo.decPendingResource(
schedulingRequest.getNodeLabelExpression(),
sizing.getResources());
}
}
{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
