Index: src/mapred/org/apache/hadoop/filecache/TrackerDistributedCacheManager.java =================================================================== --- src/mapred/org/apache/hadoop/filecache/TrackerDistributedCacheManager.java (revision 16262) +++ src/mapred/org/apache/hadoop/filecache/TrackerDistributedCacheManager.java (working copy) @@ -761,6 +762,14 @@ mgr.setSizes(sizes); } } + + public void removeTaskDistributedCacheManager(JobID jobId) { + try { + jobArchives.remove(jobId); + } catch (Exception e) { + LOG.warn(e.toString()); + } + } /** * Determines timestamps of files to be cached, and stores those Index: src/mapred/org/apache/hadoop/mapred/TaskTracker.java =================================================================== --- src/mapred/org/apache/hadoop/mapred/TaskTracker.java (revision 16262) +++ src/mapred/org/apache/hadoop/mapred/TaskTracker.java (working copy) @@ -1946,6 +1946,7 @@ runningJobs.remove(jobId); } getJobTokenSecretManager().removeTokenForJob(jobId.toString()); + distributedCacheManager.removeTaskDistributedCacheManager(jobId); } /**