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/05/14 23:42:47 UTC
incubator-tinkerpop git commit: minor tweek to GraphComputerTest.
Repository: incubator-tinkerpop
Updated Branches:
refs/heads/master 5127b5156 -> 1f37ad58b
minor tweek to GraphComputerTest.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/1f37ad58
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/1f37ad58
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/1f37ad58
Branch: refs/heads/master
Commit: 1f37ad58beb53d24a4945780aaa853c479e6326c
Parents: 5127b51
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Thu May 14 15:42:42 2015 -0600
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Thu May 14 15:42:42 2015 -0600
----------------------------------------------------------------------
.../tinkerpop/gremlin/process/computer/GraphComputerTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/1f37ad58/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/computer/GraphComputerTest.java
----------------------------------------------------------------------
diff --git a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/computer/GraphComputerTest.java b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/computer/GraphComputerTest.java
index 1e7fc5a..62421b0 100644
--- a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/computer/GraphComputerTest.java
+++ b/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/computer/GraphComputerTest.java
@@ -1032,7 +1032,7 @@ public class GraphComputerTest extends AbstractGremlinProcessTest {
MapReduceI.TIME_KEEPER.set(-1l);
MapReduceI.WORKER_START.clear();
MapReduceI.WORKER_END.clear();
- graph.compute(graphComputerClass.get()).program(new VertexProgramJ()).mapReduce(new MapReduceI()).submit().get();
+ assertEquals(3,graph.compute(graphComputerClass.get()).program(new VertexProgramJ()).mapReduce(new MapReduceI()).submit().get().memory().<Integer>get("a").intValue());
assertEquals(Long.MIN_VALUE, VertexProgramJ.TIME_KEEPER.get());
if (MapReduceI.WORKER_START.size() == 2) {
assertEquals(2, MapReduceI.WORKER_START.size());