private String getTaskCacheDirectory ( TaskControllerContext context ) { // In the case of JVM reuse, the task specific directory // is different from what is set with respect with // env.workDir. Hence building this from the taskId everytime. String taskId = context . task . getTaskID ( ) . toString ( ) ; File cacheDirForJob = context . env . workDir . getParentFile ( ) . getParentFile ( ) ; if ( context . task . isTaskCleanupTask ( ) ) { taskId = taskId + TaskTracker . TASK_CLEANUP_SUFFIX ; } return new File ( cacheDirForJob , taskId ) . getAbsolutePath ( ) ; }
Return the task specific directory under the cache .