@ SuppressWarnings ( "deprecation" ) private void localizeTaskConfiguration ( TaskTracker tracker , JobConf ttConf , String workDir , Task t , JobID jobID ) throws IOException { Path jobFile = new Path ( t . getJobFile ( ) ) ; FileSystem systemFS = tracker . systemFS ; this . localizedJobFile = new Path ( workDir , jobID + ".xml" ) ; LOG . info ( "Localizing CJT configuration from " + jobFile + " to " + localizedJobFile ) ; systemFS . copyToLocalFile ( jobFile , localizedJobFile ) ; JobConf localJobConf = new JobConf ( localizedJobFile ) ; boolean modified = Task . saveStaticResolutions ( localJobConf ) ; if ( modified ) { FSDataOutputStream out = new FSDataOutputStream ( new FileOutputStream ( localizedJobFile . toUri ( ) . getPath ( ) ) ) ; try { localJobConf . writeXml ( out ) ; } catch ( IOException e ) { out . close ( ) ; throw e ; } } // Add the values from the job conf to the configuration of this runner this . conf . addResource ( localizedJobFile ) ; }
Copies the job file to the working directory of the process that will be started .