Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
3.1.0
-
None
-
None
Description
We need to specify rack and ANY while submitting a node local resource request, as YARN-7561 discussed. For example:
ResourceRequest nodeRequest = createResourceRequest(GB, node1.getHostName(), 1, 1, false); ResourceRequest rackRequest = createResourceRequest(GB, node1.getRackName(), 1, 1, false); ResourceRequest anyRequest = createResourceRequest(GB, ResourceRequest.ANY, 1, 1, false); List<ResourceRequest> resourceRequests = Arrays.asList(nodeRequest, rackRequest, anyRequest);
However, method getStarvedResourceRequests() only consider the first encountered resource, which most likely is ResourceRequest.ANY. That's a mismatch for locality request.