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

MAPREDUCE-7151. RMContainerAllocator#handleJobPriorityChange expects application_priority always. Contributed by Bilwa S T. 

(cherry picked from commit 74a5e683fe)
This commit is contained in:
bibinchundatt 2018-10-22 15:59:14 +05:30
parent 2e43966b56
commit 4167275e89
2 changed files with 22 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/rm/RMContainerAllocator.java
View File

@ -1020,12 +1020,14 @@ public class RMContainerAllocator extends RMContainerRequestor
} }
} }
private void handleJobPriorityChange(AllocateResponse response) { void handleJobPriorityChange(AllocateResponse response) {
Priority priorityFromResponse = Priority.newInstance(response Priority applicationPriority = response.getApplicationPriority();
.getApplicationPriority().getPriority()); if (null != applicationPriority) {
Priority priorityFromResponse = Priority
// Update the job priority to Job directly. .newInstance(applicationPriority.getPriority());
getJob().setJobPriority(priorityFromResponse); // Update the job priority to Job directly.
getJob().setJobPriority(priorityFromResponse);
}
} }
@Private @Private

14
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/rm/TestRMContainerAllocator.java
View File

@ -2160,6 +2160,20 @@ public class TestRMContainerAllocator {
} }
} }
@Test
public void testIfApplicationPriorityIsNotSet() {
Job mockJob = mock(Job.class);
RMCommunicator communicator = mock(RMCommunicator.class);
ClientService service = mock(ClientService.class);
AppContext context = mock(AppContext.class);
AMPreemptionPolicy policy = mock(AMPreemptionPolicy.class);
when(communicator.getJob()).thenReturn(mockJob);
RMContainerAllocator allocator = new RMContainerAllocator(service, context,
policy);
AllocateResponse response = Records.newRecord(AllocateResponse.class);
allocator.handleJobPriorityChange(response);
}
@Test @Test
public void testReduceScheduling() throws Exception { public void testReduceScheduling() throws Exception {
int totalMaps = 10; int totalMaps = 10;