You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by im...@apache.org on 2021/06/04 19:48:24 UTC

[asterixdb] 01/04: [NO ISSUE][RT] Fix flush() of subplan runtime

This is an automated email from the ASF dual-hosted git repository.

imaxon pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb.git

commit 2ff3036a79412117a8df050a57d94be4a690859c
Author: Ali Alsuliman <al...@gmail.com>
AuthorDate: Wed May 26 17:11:48 2021 +0300

    [NO ISSUE][RT] Fix flush() of subplan runtime
    
    - user model changes: no
    - storage format changes: no
    - interface changes: no
    
    Details:
    flush() of Subplan runtime should flush its appender
    to the next writer.
    
    Change-Id: Ib0d7ff82381e5c6dcea6d26ccbfba71530cc07a7
    Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/11643
    Integration-Tests: Jenkins <je...@fulliautomatix.ics.uci.edu>
    Tested-by: Jenkins <je...@fulliautomatix.ics.uci.edu>
    Reviewed-by: Ali Alsuliman <al...@gmail.com>
    Reviewed-by: Murtadha Hubail <mh...@apache.org>
---
 .../algebricks/runtime/operators/meta/SubplanRuntimeFactory.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/meta/SubplanRuntimeFactory.java b/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/meta/SubplanRuntimeFactory.java
index 3cee12d..6497fdc 100644
--- a/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/meta/SubplanRuntimeFactory.java
+++ b/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/meta/SubplanRuntimeFactory.java
@@ -191,7 +191,7 @@ public class SubplanRuntimeFactory extends AbstractOneInputOneOutputRuntimeFacto
 
         @Override
         public void flush() throws HyracksDataException {
-            writer.flush();
+            appender.flush(writer);
         }
 
         /**