abdullah alamoudi has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/528
Change subject: ASTERIXDB-1144 Ensure close of a feed store node completes
......................................................................
ASTERIXDB-1144 Ensure close of a feed store node completes
This change ensures that the feed store node completely close when the feed
has no more data. This is accomplished by notifying the core oprtator
when processing of the last frame has been completed.
Change-Id: If36c9bd6a8ce794ca8e7eb796e2b8fe5b0e9e948
---
M
asterix-common/src/main/java/org/apache/asterix/common/feeds/FeedRuntimeInputHandler.java
1 file changed, 9 insertions(+), 2 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/28/528/1
diff --git
a/asterix-common/src/main/java/org/apache/asterix/common/feeds/FeedRuntimeInputHandler.java
b/asterix-common/src/main/java/org/apache/asterix/common/feeds/FeedRuntimeInputHandler.java
index 6642df1..76b7cb1 100644
---
a/asterix-common/src/main/java/org/apache/asterix/common/feeds/FeedRuntimeInputHandler.java
+++
b/asterix-common/src/main/java/org/apache/asterix/common/feeds/FeedRuntimeInputHandler.java
@@ -245,8 +245,15 @@
while (!frameProcessed) {
try {
if (!bufferingEnabled) {
- coreOperator.nextFrame(frame); // synchronous
- mBuffer.sendReport(frame);
+ if (frame == null) {
+ setFinished(true);
+ synchronized (coreOperator) {
+ coreOperator.notifyAll();
+ }
+ } else {
+ coreOperator.nextFrame(frame); // synchronous
+ mBuffer.sendReport(frame);
+ }
} else {
DataBucket bucket = pool.getDataBucket();
if (bucket != null) {
--
To view, visit https://asterix-gerrit.ics.uci.edu/528
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: If36c9bd6a8ce794ca8e7eb796e2b8fe5b0e9e948
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: abdullah alamoudi <[email protected]>
