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/03/22 21:53:36 UTC
[11/12] incubator-tinkerpop git commit: minor nothing logic tweak.
minor nothing logic tweak.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/32afb58a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/32afb58a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/32afb58a
Branch: refs/heads/master
Commit: 32afb58aead3cfeb61973b0c4748c691621ad91f
Parents: 20e9ed1
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Tue Mar 22 10:21:22 2016 -0600
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Tue Mar 22 10:21:22 2016 -0600
----------------------------------------------------------------------
.../process/computer/traversal/TraversalVertexProgram.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/32afb58a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/TraversalVertexProgram.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/TraversalVertexProgram.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/TraversalVertexProgram.java
index 666a803..0cd873f 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/TraversalVertexProgram.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/traversal/TraversalVertexProgram.java
@@ -144,8 +144,9 @@ public final class TraversalVertexProgram implements VertexProgram<TraverserSet<
// if results will be serialized out, don't save halted traversers across the cluster
this.keepDistributedHaltedTraversers =
!(this.traversal.get().getParent().asStep().getNextStep() instanceof ComputerResultStep || // if its just going to stream it out, don't distribute
- this.traversal.get().getParent().asStep().getNextStep().getNextStep() instanceof ComputerResultStep ||
- this.traversal.get().getParent().asStep().getNextStep() instanceof EmptyStep); // same as above, but if using TraversalVertexProgramStep directly
+ this.traversal.get().getParent().asStep().getNextStep() instanceof EmptyStep || // same as above, but if using TraversalVertexProgramStep directly
+ (this.traversal.get().getParent().asStep().getNextStep() instanceof ProfileStep && // same as above, but needed for profiling
+ this.traversal.get().getParent().asStep().getNextStep().getNextStep() instanceof ComputerResultStep));
// register traversal side-effects in memory
final TraversalSideEffects sideEffects = ((MemoryTraversalSideEffects) this.traversal.get().getSideEffects()).getSideEffects();
sideEffects.keys().forEach(key -> this.memoryComputeKeys.add(MemoryComputeKey.of(key, sideEffects.getReducer(key), true, false)));