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 2015/03/26 00:43:51 UTC
incubator-tinkerpop git commit: last attempt for @dkuppitz.
Repository: incubator-tinkerpop
Updated Branches:
refs/heads/master 8375104d8 -> cab30ca10
last attempt for @dkuppitz.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/cab30ca1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/cab30ca1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/cab30ca1
Branch: refs/heads/master
Commit: cab30ca109cf475a08235fe3c3efc3fc87610285
Parents: 8375104
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Wed Mar 25 17:43:48 2015 -0600
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Wed Mar 25 17:43:48 2015 -0600
----------------------------------------------------------------------
.../gremlin/hadoop/process/computer/spark/util/SparkHelper.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/cab30ca1/hadoop-gremlin/src/main/java/org/apache/tinkerpop/gremlin/hadoop/process/computer/spark/util/SparkHelper.java
----------------------------------------------------------------------
diff --git a/hadoop-gremlin/src/main/java/org/apache/tinkerpop/gremlin/hadoop/process/computer/spark/util/SparkHelper.java b/hadoop-gremlin/src/main/java/org/apache/tinkerpop/gremlin/hadoop/process/computer/spark/util/SparkHelper.java
index cbccc58..7696f3a 100644
--- a/hadoop-gremlin/src/main/java/org/apache/tinkerpop/gremlin/hadoop/process/computer/spark/util/SparkHelper.java
+++ b/hadoop-gremlin/src/main/java/org/apache/tinkerpop/gremlin/hadoop/process/computer/spark/util/SparkHelper.java
@@ -65,6 +65,7 @@ public final class SparkHelper {
workerVertexProgram.workerIterationStart(memory);
final List<Tuple2<Object, SparkPayload<M>>> emission = new ArrayList<>();
partitionIterator.forEachRemaining(keyValue -> {
+ keyValue._2().asVertexPayload().getOutgoingMessages().clear();
workerVertexProgram.execute(ComputerGraph.of(keyValue._2().asVertexPayload().getVertex(), elementComputeKeys), keyValue._2().asVertexPayload(), memory);
emission.add(keyValue);
});
@@ -104,7 +105,6 @@ public final class SparkHelper {
// clear all previous outgoing messages (why can't we do this prior to the shuffle? -- this is probably cause of concurrent modification issues prior to reduceByKey)
current = current.mapValues(vertexPayload -> {
- // vertexPayload.asVertexPayload().getMessages().clear();
vertexPayload.asVertexPayload().getOutgoingMessages().clear();
return vertexPayload;
});