You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by ok...@apache.org on 2016/01/21 15:38:33 UTC
incubator-tinkerpop git commit: YARN and MapReduce behave different
for computing slots. Removing this calculation until we can figure out a
general solution. CTR.
Repository: incubator-tinkerpop
Updated Branches:
refs/heads/master b27d6539a -> 889e38e5a
YARN and MapReduce behave different for computing slots. Removing this calculation until we can figure out a general solution. CTR.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/889e38e5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/889e38e5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/889e38e5
Branch: refs/heads/master
Commit: 889e38e5ae85d81632caecdaa4fbf62599934df7
Parents: b27d653
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Thu Jan 21 07:38:37 2016 -0700
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Thu Jan 21 07:38:37 2016 -0700
----------------------------------------------------------------------
.../gremlin/giraph/process/computer/GiraphGraphComputer.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/889e38e5/giraph-gremlin/src/main/java/org/apache/tinkerpop/gremlin/giraph/process/computer/GiraphGraphComputer.java
----------------------------------------------------------------------
diff --git a/giraph-gremlin/src/main/java/org/apache/tinkerpop/gremlin/giraph/process/computer/GiraphGraphComputer.java b/giraph-gremlin/src/main/java/org/apache/tinkerpop/gremlin/giraph/process/computer/GiraphGraphComputer.java
index 82b3ec1..18bb25e 100644
--- a/giraph-gremlin/src/main/java/org/apache/tinkerpop/gremlin/giraph/process/computer/GiraphGraphComputer.java
+++ b/giraph-gremlin/src/main/java/org/apache/tinkerpop/gremlin/giraph/process/computer/GiraphGraphComputer.java
@@ -57,7 +57,6 @@ import org.apache.tinkerpop.gremlin.structure.io.Storage;
import org.apache.tinkerpop.gremlin.util.Gremlin;
import java.io.File;
-import java.io.IOException;
import java.io.NotSerializableException;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Executor;
@@ -271,14 +270,16 @@ public final class GiraphGraphComputer extends AbstractHadoopGraphComputer imple
if (GiraphGraphComputer.this.giraphConfiguration.getLocalTestMode())
return Runtime.getRuntime().availableProcessors();
else {
- try {
+ return Integer.MAX_VALUE;
+ /*try {
final Cluster cluster = new Cluster(GiraphGraphComputer.this.giraphConfiguration);
int maxWorkers = (cluster.getClusterStatus().getMapSlotCapacity() - 1) * 16; // max 16 threads per machine hardcoded :|
cluster.close();
return maxWorkers;
+
} catch (final IOException | InterruptedException e) {
throw new IllegalStateException(e.getMessage(), e);
- }
+ }*/
}
}
}