Xikui Wang has uploaded a new change for review. https://asterix-gerrit.ics.uci.edu/3256
Change subject: [NO ISSUE][RT] Fix flush in OneFramePushRuntime ...................................................................... [NO ISSUE][RT] Fix flush in OneFramePushRuntime - user model changes: no - storage format changes: no - interface changes: no Details: The AbstractOneInputOneOutputOneFramePushRuntime doesn't flush data records in its flushAndReset() method. This causes the data records are not flushed as expected if there is a partitioned connected after it. In data feeds particularly, when the feeding rate is low, the ingested data will not be able to be queried, even if they are ingested for a very long time. Change-Id: I2c2768a41fb9d23f8ce990c8c5c52ec14c2319e5 --- M hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/base/AbstractOneInputOneOutputOneFramePushRuntime.java 1 file changed, 1 insertion(+), 0 deletions(-) git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb refs/changes/56/3256/1 diff --git a/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/base/AbstractOneInputOneOutputOneFramePushRuntime.java b/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/base/AbstractOneInputOneOutputOneFramePushRuntime.java index 71b44d3..81edfe0 100644 --- a/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/base/AbstractOneInputOneOutputOneFramePushRuntime.java +++ b/hyracks-fullstack/algebricks/algebricks-runtime/src/main/java/org/apache/hyracks/algebricks/runtime/operators/base/AbstractOneInputOneOutputOneFramePushRuntime.java @@ -72,6 +72,7 @@ protected void flushAndReset() throws HyracksDataException { if (appender.getTupleCount() > 0) { appender.write(writer, true); + writer.flush(); } } -- To view, visit https://asterix-gerrit.ics.uci.edu/3256 To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings Gerrit-MessageType: newchange Gerrit-Change-Id: I2c2768a41fb9d23f8ce990c8c5c52ec14c2319e5 Gerrit-PatchSet: 1 Gerrit-Project: asterixdb Gerrit-Branch: master Gerrit-Owner: Xikui Wang <xkk...@gmail.com>