>From Hussain Towaileb <[email protected]>:
Hussain Towaileb has uploaded this change for review. (
https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/18349 )
Change subject: Testing socket timeout
......................................................................
Testing socket timeout
Change-Id: Ic9d82dc3c1e358efe9c196aa322824349a0e0ef4
---
M
asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/aws/AwsS3InputStream.java
1 file changed, 10 insertions(+), 0 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/49/18349/1
diff --git
a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/aws/AwsS3InputStream.java
b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/aws/AwsS3InputStream.java
index 7a1bdad..50787f1 100644
---
a/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/aws/AwsS3InputStream.java
+++
b/asterixdb/asterix-external-data/src/main/java/org/apache/asterix/external/input/record/reader/aws/AwsS3InputStream.java
@@ -63,6 +63,7 @@
@Override
protected boolean getInputStream() throws IOException {
String fileName = filePaths.get(nextFileIndex);
+ LOGGER.info("Reading: {}", fileName);
GetObjectRequest.Builder getObjectBuilder = GetObjectRequest.builder();
GetObjectRequest getObjectRequest =
getObjectBuilder.bucket(bucket).key(filePaths.get(nextFileIndex)).build();
// Have a reference to the S3 stream to ensure that if GZipInputStream
causes an IOException because of reading
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/18349
To unsubscribe, or for help writing mail filters, visit
https://asterix-gerrit.ics.uci.edu/settings
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Change-Id: Ic9d82dc3c1e358efe9c196aa322824349a0e0ef4
Gerrit-Change-Number: 18349
Gerrit-PatchSet: 1
Gerrit-Owner: Hussain Towaileb <[email protected]>
Gerrit-MessageType: newchange
