tinkerpop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From spmalle...@apache.org
Subject [tinkerpop] 08/27: TINKERPOP-2076 Fixed bad merge operation in the MemoryAccumulator
Date Mon, 06 Apr 2020 12:41:39 GMT
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 ad1279614cccfe1bda0a310dd5bcc30e7804c0be
Author: stephen <spmallette@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()));
     }
 


Mime
View raw message