private void cleanJobDirectory ( ) { try { FileSystem jobfs = jobDirectory . getFileSystem ( conf ) ; jobfs . delete ( jobDirectory , true ) ; } catch ( IOException ioe ) { LOG . warn ( "Unable to clean tmp directory " + jobDirectory , ioe ) ; } }
delete the tmp job directory