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 <[email protected]>
