You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by tg...@apache.org on 2012/09/25 16:38:18 UTC

svn commit: r1389888 - in /hadoop/common/branches/branch-1: CHANGES.txt src/mapred/org/apache/hadoop/mapred/JobHistory.java

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) {