This is an automated email from the ASF dual-hosted git repository. dkuppitz pushed a commit to branch TINKERPOP-2076 in repository https://gitbox.apache.org/repos/asf/tinkerpop.git
commit 4d9c3358ebb795c8d1d62ad71c895981ab1466a9 Author: stephen <spmalle...@gmail.com> 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())); }