commit | 2ff3036a79412117a8df050a57d94be4a690859c | [log] [tgz] |
---|---|---|
author | Ali Alsuliman <ali.al.solaiman@gmail.com> | Wed May 26 17:11:48 2021 +0300 |
committer | Ali Alsuliman <ali.al.solaiman@gmail.com> | Wed May 26 23:26:38 2021 +0000 |
tree | a698f2e9e5f3ad8ad1d8e30cbe6710d8c82a3606 | |
parent | d5de9eb65fa935076d0bb82094d3fdf5357ea704 [diff] |
[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 <jenkins@fulliautomatix.ics.uci.edu> Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Reviewed-by: Ali Alsuliman <ali.al.solaiman@gmail.com> Reviewed-by: Murtadha Hubail <mhubail@apache.org>
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 @@ @Override public void flush() throws HyracksDataException { - writer.flush(); + appender.flush(writer); } /**