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/04/10 01:27:09 UTC
incubator-tinkerpop git commit: minor tweak to SparkMessenger.
Repository: incubator-tinkerpop
Updated Branches:
refs/heads/master ec99f516e -> 5b7ad6ff6
minor tweak to SparkMessenger.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/5b7ad6ff
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/5b7ad6ff
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/5b7ad6ff
Branch: refs/heads/master
Commit: 5b7ad6ff694b161ef1dd7375858500f9f853ec6f
Parents: ec99f51
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Thu Apr 9 17:27:24 2015 -0600
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Thu Apr 9 17:27:24 2015 -0600
----------------------------------------------------------------------
.../gremlin/hadoop/process/computer/spark/SparkMessenger.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/5b7ad6ff/hadoop-gremlin/src/main/java/org/apache/tinkerpop/gremlin/hadoop/process/computer/spark/SparkMessenger.java
----------------------------------------------------------------------
diff --git a/hadoop-gremlin/src/main/java/org/apache/tinkerpop/gremlin/hadoop/process/computer/spark/SparkMessenger.java b/hadoop-gremlin/src/main/java/org/apache/tinkerpop/gremlin/hadoop/process/computer/spark/SparkMessenger.java
index f3f8e33..01153a1 100644
--- a/hadoop-gremlin/src/main/java/org/apache/tinkerpop/gremlin/hadoop/process/computer/spark/SparkMessenger.java
+++ b/hadoop-gremlin/src/main/java/org/apache/tinkerpop/gremlin/hadoop/process/computer/spark/SparkMessenger.java
@@ -40,12 +40,12 @@ public final class SparkMessenger<M> implements Messenger<M> {
private Vertex vertex;
private Iterable<M> incomingMessages;
- private final List<Tuple2<Object, M>> outgoingMessages = new ArrayList<>();
+ private List<Tuple2<Object, M>> outgoingMessages = new ArrayList<>();
public void setVertexAndIncomingMessages(final Vertex vertex, final Iterable<M> incomingMessages) {
this.vertex = vertex;
this.incomingMessages = incomingMessages;
- this.outgoingMessages.clear();
+ this.outgoingMessages = new ArrayList<>();
}
public List<Tuple2<Object, M>> getOutgoingMessages() {