Author: tgraves Date: Tue Sep 25 14:38:17 2012 New Revision: 1389888 URL: http://svn.apache.org/viewvc?rev=1389888&view=rev Log: MAPREDUCE-4662. JobHistoryFilesManager thread pool never expands (Kihwal Lee via tgraves)
Modified: hadoop/common/branches/branch-1/CHANGES.txt hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/JobHistory.java Modified: hadoop/common/branches/branch-1/CHANGES.txt URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-1/CHANGES.txt?rev=1389888&r1=1389887&r2=1389888&view=diff ============================================================================== --- hadoop/common/branches/branch-1/CHANGES.txt (original) +++ hadoop/common/branches/branch-1/CHANGES.txt Tue Sep 25 14:38:17 2012 @@ -254,6 +254,9 @@ Release 1.2.0 - unreleased MAPREDUCE-4652. ValueAggregatorJob sets the wrong job jar. (Ahmed Radwan via tomwhite) + MAPREDUCE-4662. JobHistoryFilesManager thread pool never expands + (Kihwal Lee via tgraves) + Release 1.1.0 - unreleased INCOMPATIBLE CHANGES Modified: hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/JobHistory.java URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/JobHistory.java?rev=1389888&r1=1389887&r2=1389888&view=diff ============================================================================== --- hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/JobHistory.java (original) +++ hadoop/common/branches/branch-1/src/mapred/org/apache/hadoop/mapred/JobHistory.java Tue Sep 25 14:38:17 2012 @@ -221,8 +221,11 @@ public class JobHistory { void start() { - executor = new ThreadPoolExecutor(1, 3, 1, + executor = new ThreadPoolExecutor(5, 5, 1, TimeUnit.HOURS, new LinkedBlockingQueue<Runnable>()); + // make core threads to terminate if there has been no work + // for the keppalive period. + executor.allowCoreThreadTimeOut(true); } private FilesHolder getFileHolder(JobID id) {