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

MAPREDUCE-6492. AsyncDispatcher exit with NPE on TaskAttemptImpl#sendJHStartEventForAssignedFailTask. Contributed by Bibin A Chundatt

Browse Source 
(cherry picked from commit ab11085b81353e1617875deb10f3c8e2a8b91a1e)
This commit is contained in:
Jason Lowe 2015-09-28 22:12:03 +00:00
parent 6e7c76a5bd
commit fc10c99839
3 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hadoop-mapreduce-project/CHANGES.txt
View File

@ -41,6 +41,10 @@ Release 2.7.2 - UNRELEASED
MAPREDUCE-5982. Task attempts that fail from the ASSIGNED state can MAPREDUCE-5982. Task attempts that fail from the ASSIGNED state can
disappear (Chang Li via jlowe) disappear (Chang Li via jlowe)
MAPREDUCE-6492. AsyncDispatcher exit with NPE on
TaskAttemptImpl#sendJHStartEventForAssignedFailTask (Bibin A Chundatt via
jlowe)
Release 2.7.1 - 2015-07-06 Release 2.7.1 - 2015-07-06
INCOMPATIBLE CHANGES INCOMPATIBLE CHANGES

4
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/job/impl/TaskAttemptImpl.java
View File

@ -1380,7 +1380,9 @@ private static JobCounterUpdateEvent createJobCounterUpdateEventTAKilled(
private static void private static void
sendJHStartEventForAssignedFailTask(TaskAttemptImpl taskAttempt) { sendJHStartEventForAssignedFailTask(TaskAttemptImpl taskAttempt) {
TaskAttemptContainerLaunchedEvent event; if (null == taskAttempt.container) {
return;
}
taskAttempt.launchTime = taskAttempt.clock.getTime(); taskAttempt.launchTime = taskAttempt.clock.getTime();
InetSocketAddress nodeHttpInetAddr = InetSocketAddress nodeHttpInetAddr =

8
hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/job/impl/TestTaskAttempt.java
View File

@ -753,6 +753,14 @@ public void testAppDiognosticEventOnUnassignedTask() throws Exception {
assertFalse( assertFalse(
"InternalError occurred trying to handle TA_DIAGNOSTICS_UPDATE on assigned task", "InternalError occurred trying to handle TA_DIAGNOSTICS_UPDATE on assigned task",
eventHandler.internalError); eventHandler.internalError);
try {
taImpl.handle(new TaskAttemptEvent(attemptId,
TaskAttemptEventType.TA_KILL));
Assert.assertTrue("No exception on UNASSIGNED STATE KILL event", true);
} catch (Exception e) {
Assert.assertFalse(
"Exception not expected for UNASSIGNED STATE KILL event", true);
}
} }
@Test @Test