void markCompletedTaskAttempt ( String taskTracker , TaskAttemptID taskid ) { // tracker --> taskid Set < TaskAttemptID > taskset = trackerToMarkedTasksMap . get ( taskTracker ) ; if ( taskset == null ) { taskset = new TreeSet < TaskAttemptID > ( ) ; trackerToMarkedTasksMap . put ( taskTracker , taskset ) ; } taskset . add ( taskid ) ; LOG . debug ( "Marked '" + taskid + "' from '" + taskTracker + "'" ) ; }
Mark a task for removal later . This function assumes that the JobTracker is locked on entry .