private void setupTaskCacheFileAccess ( TaskControllerContext context ) { String taskId = context . task . getTaskID ( ) . toString ( ) ; JobID jobId = JobID . forName ( getJobId ( context ) ) ; //Change permission for the task across all the disks for ( String localDir : mapredLocalDirs ) { File f = new File ( localDir ) ; File taskCacheDir = new File ( f , TaskTracker . getLocalTaskDir ( jobId . toString ( ) , taskId , context . task . isTaskCleanupTask ( ) ) ) ; if ( taskCacheDir . exists ( ) ) { changeDirectoryPermissions ( taskCacheDir . getPath ( ) , FILE_PERMISSIONS , true ) ; } } //end of local directory Iteration }
the files under the job and task cache directories