public void setupJob ( JobContext context ) throws IOException { if ( outputPath != null ) { Path tmpDir = new Path ( outputPath , FileOutputCommitter . TEMP_DIR_NAME ) ; FileSystem fileSys = tmpDir . getFileSystem ( context . getConfiguration ( ) ) ; if ( ! fileSys . mkdirs ( tmpDir ) ) { LOG . error ( "Mkdirs failed to create " + tmpDir . toString ( ) ) ; } } }
Create the temporary directory that is the root of all of the task work directories .