hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1104034 - /incubator/hama/trunk/src/java/org/apache/hama/bsp/LocalBSPRunner.java
Date Tue, 17 May 2011 07:23:42 GMT
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);



Mime
View raw message