hama-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From edwardy...@apache.org
Subject svn commit: r1673621 - /hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java
Date Wed, 15 Apr 2015 02:29:18 GMT
Author: edwardyoon
Date: Wed Apr 15 02:29:17 2015
New Revision: 1673621

URL: http://svn.apache.org/r1673621
Log:
Fix build fails.

Modified:
    hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java

Modified: hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java
URL: http://svn.apache.org/viewvc/hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java?rev=1673621&r1=1673620&r2=1673621&view=diff
==============================================================================
--- hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java (original)
+++ hama/trunk/graph/src/main/java/org/apache/hama/graph/GraphJobRunner.java Wed Apr 15 02:29:17
2015
@@ -278,8 +278,8 @@ public final class GraphJobRunner<V exte
     this.changedVertexCnt = 0;
     vertices.startSuperstep();
 
-    ExecutorService executor = Executors.newFixedThreadPool(vertices.size()
-        / conf.getInt("hama.graph.threadpool.percentage", 10));
+    ExecutorService executor = Executors.newFixedThreadPool((vertices.size()
+        / conf.getInt("hama.graph.threadpool.percentage", 10)) + 1);
 
     for (Vertex<V, E, M> v : vertices.getValues()) {
       Runnable worker = new ComputeRunnable(v, Collections.singleton(v



Mime
View raw message