public void logFinished ( long finishTime , int finishedMaps , int finishedReduces , int failedMaps , int failedReduces , int killedMaps , int killedReduces , Counters mapCounters , Counters reduceCounters , Counters counters ) { if ( disableHistory ) { return ; } if ( null != writers ) { log ( writers , RecordTypes . Job , new Keys [ ] { Keys . JOBID , Keys . FINISH_TIME , Keys . JOB_STATUS , Keys . FINISHED_MAPS , Keys . FINISHED_REDUCES , Keys . FAILED_MAPS , Keys . FAILED_REDUCES , Keys . KILLED_MAPS , Keys . KILLED_REDUCES , Keys . MAP_COUNTERS , Keys . REDUCE_COUNTERS , Keys . COUNTERS } , new String [ ] { jobId . toString ( ) , Long . toString ( finishTime ) , Values . SUCCESS . name ( ) , String . valueOf ( finishedMaps ) , String . valueOf ( finishedReduces ) , String . valueOf ( failedMaps ) , String . valueOf ( failedReduces ) , String . valueOf ( killedMaps ) , String . valueOf ( killedReduces ) , mapCounters . makeEscapedCompactString ( ) , reduceCounters . makeEscapedCompactString ( ) , counters . makeEscapedCompactString ( ) } , true ) ; closeAndClear ( writers ) ; } // NOTE: history cleaning stuff deleted from here. We should do that // somewhere else! }
Log job finished . closes the job file in history .