You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hama.apache.org by ed...@apache.org on 2011/05/17 09:23:42 UTC

svn commit: r1104034 - /incubator/hama/trunk/src/java/org/apache/hama/bsp/LocalBSPRunner.java

Author: edwardyoon
Date: Tue May 17 07:23:41 2011
New Revision: 1104034

URL: http://svn.apache.org/viewvc?rev=1104034&view=rev
Log:
a trivial code change.

Modified:
    incubator/hama/trunk/src/java/org/apache/hama/bsp/LocalBSPRunner.java

Modified: incubator/hama/trunk/src/java/org/apache/hama/bsp/LocalBSPRunner.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/src/java/org/apache/hama/bsp/LocalBSPRunner.java?rev=1104034&r1=1104033&r2=1104034&view=diff
==============================================================================
--- incubator/hama/trunk/src/java/org/apache/hama/bsp/LocalBSPRunner.java (original)
+++ incubator/hama/trunk/src/java/org/apache/hama/bsp/LocalBSPRunner.java Tue May 17 07:23:41 2011
@@ -78,8 +78,7 @@ public class LocalBSPRunner implements J
     if (path != null && !path.isEmpty())
       WORKING_DIR = path;
 
-    int overridenSize = conf.getInt("bsp.local.tasks.maximum", 20);
-    threadPoolSize = overridenSize;
+    threadPoolSize = conf.getInt("bsp.local.tasks.maximum", 20);
     threadPool = (ThreadPoolExecutor) Executors
         .newFixedThreadPool(threadPoolSize);
     barrier = new CyclicBarrier(threadPoolSize);