synchronized void cleanUpOverMemoryTask ( TaskAttemptID tid , boolean wasFailure , String diagnosticMsg ) { TaskInProgress tip = runningTasks . get ( tid ) ; if ( tip != null ) { tip . reportDiagnosticInfo ( diagnosticMsg ) ; try { purgeTask ( tip , wasFailure ) ; // Marking it as failed/killed. } catch ( IOException ioe ) { LOG . warn ( "Couldn't purge the task of " + tid + ". Error : " + ioe ) ; } } }
Clean - up the task that TaskMemoryMangerThread requests to do so .