>From Hussain Towaileb <hussai...@gmail.com>: 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 <hussai...@gmail.com> Gerrit-MessageType: newchange