Details
-
Improvement
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
-
None
Description
Since the taskCommitThread ensures that one and only one task of a given TIP is marked as SUCCEEDED, we don't need the code block in JobInProgress.completedTask which checks if the TIP is complete and then just marks the task as complete:
// Sanity check: is the TIP already complete? if (tip.isComplete()) { // Mark this task as KILLED tip.alreadyCompletedTask(taskid); // Let the JobTracker cleanup this taskid if the job isn't running if (this.status.getRunState() != JobStatus.RUNNING) { jobtracker.markCompletedTaskAttempt(status.getTaskTracker(), taskid); } return false; }