This is an automated email from the ASF dual-hosted git repository. spmallette pushed a commit to branch TINKERPOP-2076 in repository https://gitbox.apache.org/repos/asf/tinkerpop.git
commit 1faae55c505581fb1a13988fa2f27250a827506a Author: stephen <[email protected]> AuthorDate: Tue Nov 12 05:06:58 2019 -0500 TINKERPOP-2076 Fixed bad merge operation in the MemoryAccumulator --- .../tinkerpop/gremlin/spark/process/computer/MemoryAccumulator.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/MemoryAccumulator.java b/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/MemoryAccumulator.java index cc7b8de..fa72eb0 100644 --- a/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/MemoryAccumulator.java +++ b/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/MemoryAccumulator.java @@ -60,7 +60,7 @@ public final class MemoryAccumulator<A> extends AccumulatorV2<ObjectWritable<A>, public void add(final ObjectWritable<A> v) { if (this.value.isEmpty()) this.value = v; - if (!v.isEmpty()) + else if (!v.isEmpty()) this.value = new ObjectWritable<>(this.memoryComputeKey.getReducer().apply(value.get(), v.get())); }
