abdullah alamoudi has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/709
Change subject: Flush Socket feed when no more data in input stream
......................................................................
Flush Socket feed when no more data in input stream
Change-Id: Ic37085114592e97b6c5b2d29c5451d816a154aa8
---
M
asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/SocketInputStream.java
1 file changed, 5 insertions(+), 0 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/09/709/1
diff --git
a/asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/SocketInputStream.java
b/asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/SocketInputStream.java
index cf8d339..67c4493 100644
---
a/asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/SocketInputStream.java
+++
b/asterix-external-data/src/main/java/org/apache/asterix/external/input/stream/SocketInputStream.java
@@ -33,6 +33,7 @@
private ServerSocket server;
private Socket socket;
private InputStream connectionStream;
+ private AbstractFeedDataFlowController controller;
public SocketInputStream(ServerSocket server) throws IOException {
this.server = server;
@@ -73,6 +74,9 @@
}
int read = -1;
try {
+ if (connectionStream.available() < 1) {
+ controller.flush();
+ }
read = connectionStream.read(b, off, len);
} catch (IOException e) {
e.printStackTrace();
@@ -166,5 +170,6 @@
@Override
public void setController(AbstractFeedDataFlowController controller) {
+ this.controller = controller;
}
}
--
To view, visit https://asterix-gerrit.ics.uci.edu/709
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: Ic37085114592e97b6c5b2d29c5451d816a154aa8
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: abdullah alamoudi <[email protected]>
