[GIE Compiler] fix bugs of group result

alibaba · Feb 4, 2024 · 355db36 · 355db36
1 parent 9228223
commit 355db36
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...rc/main/java/com/alibaba/graphscope/gremlin/result/processor/AbstractResultProcessor.java b/...rc/main/java/com/alibaba/graphscope/gremlin/result/processor/AbstractResultProcessor.java
@@ -19,6 +19,7 @@
 import com.alibaba.graphscope.common.config.QueryTimeoutConfig;
 import com.alibaba.graphscope.common.result.ResultParser;
 import com.alibaba.graphscope.gremlin.plugin.QueryStatusCallback;
+import com.alibaba.graphscope.gremlin.result.GroupResultParser;
 import com.alibaba.pegasus.intf.ResultProcessor;
 import com.alibaba.pegasus.service.protocol.PegasusClient;
 
@@ -82,7 +83,8 @@ public synchronized void process(PegasusClient.JobResponse response) {
             if (isContextWritable) {
                 // send back a page of results if batch size is met and then reset the
                 // resultCollectors
-                if (this.resultCollectors.size() >= this.resultCollectorsBatchSize) {
+                if (this.resultCollectors.size() >= this.resultCollectorsBatchSize
+                        && !(resultParser instanceof GroupResultParser)) {
                     aggregateResults();
                     writeResultList(
                             writeResult, resultCollectors, ResponseStatusCode.PARTIAL_CONTENT);