[
https://issues.apache.org/jira/browse/YARN-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16971342#comment-16971342
]
Bibin Chundatt edited comment on YARN-9697 at 11/11/19 7:03 AM:
----------------------------------------------------------------
[~abmodi]
Few minor Nits:
# NodeQueueLoadMonitor following set is not required , already getting set in
constructor .
{code}
private int numNodesForAnyAllocation =
DEFAULT_OPP_CONTAINER_ALLOCATION_NODES_NUMBER_USED;
{code}
Set to zero should be fine.
# EnrichedResourceRequest : rename methods since we are returning maps now.
Improvement:
# CentralizedOpportunisticContainerAllocator # allocatePerSchedulerKey : Can
you maintain a metrics to avoid iterating through allocations for each
scheduler key
{noformat}
152 for (List<Allocation> allocs : allocations.values()) {
153 totalAllocated += allocs.size();
154 }
{noformat}
was (Author: bibinchundatt):
[~abmodi]
Few minor Nits:
# NodeQueueLoadMonitor following set is not required , already getting set in
constructor
{code}
private int numNodesForAnyAllocation =
DEFAULT_OPP_CONTAINER_ALLOCATION_NODES_NUMBER_USED;
{code}
# EnrichedResourceRequest : rename methods since we are returning maps now.
Improvement:
# CentralizedOpportunisticContainerAllocator # allocatePerSchedulerKey : Can
you maintain a metrics to avoid iterating through allocations for each
scheduler key
{noformat}
152 for (List<Allocation> allocs : allocations.values()) {
153 totalAllocated += allocs.size();
154 }
{noformat}
> Efficient allocation of Opportunistic containers.
> -------------------------------------------------
>
> Key: YARN-9697
> URL: https://issues.apache.org/jira/browse/YARN-9697
> Project: Hadoop YARN
> Issue Type: Sub-task
> Reporter: Abhishek Modi
> Assignee: Abhishek Modi
> Priority: Major
> Attachments: YARN-9697.001.patch, YARN-9697.002.patch,
> YARN-9697.003.patch, YARN-9697.004.patch, YARN-9697.005.patch,
> YARN-9697.006.patch, YARN-9697.007.patch, YARN-9697.008.patch,
> YARN-9697.ut.patch, YARN-9697.ut2.patch, YARN-9697.wip1.patch,
> YARN-9697.wip2.patch
>
>
> In the current implementation, opportunistic containers are allocated based
> on the number of queued opportunistic container information received in node
> heartbeat. This information becomes stale as soon as more opportunistic
> containers are allocated on that node.
> Allocation of opportunistic containers happens on the same heartbeat in which
> AM asks for the containers. When multiple applications request for
> Opportunistic containers, containers might get allocated on the same set of
> nodes as already allocated containers on the node are not considered while
> serving requests from different applications. This can lead to uneven
> allocation of Opportunistic containers across the cluster leading to
> increased queuing time
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
