commit | 02ff31b80662fc7162b0d584053470255d853a79 | [log] [tgz] |
---|---|---|
author | Hussain Towaileb <Hussain.Towaileb@couchbase.com> | Tue Jun 06 05:59:20 2023 +0300 |
committer | Hussain Towaileb <hussainht@gmail.com> | Tue Jun 06 03:09:47 2023 +0000 |
tree | 22fcfa8afa06346fb3d97f5f1d697bc9e1a48a41 | |
parent | a13a66c37534fd1f0332fd1099c0041a7002580d [diff] |
[NO ISSUE][*DB]: Close stream after done reading Change-Id: I9f365430811a62c513219b4257788746e22d684e Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/17591 Reviewed-by: Ian Maxon <imaxon@uci.edu> Tested-by: Hussain Towaileb <hussainht@gmail.com> Integration-Tests: Hussain Towaileb <hussainht@gmail.com>
diff --git a/asterixdb/asterix-cloud/src/main/java/org/apache/asterix/cloud/clients/aws/s3/S3CloudClient.java b/asterixdb/asterix-cloud/src/main/java/org/apache/asterix/cloud/clients/aws/s3/S3CloudClient.java index 6db784d..0b78682 100644 --- a/asterixdb/asterix-cloud/src/main/java/org/apache/asterix/cloud/clients/aws/s3/S3CloudClient.java +++ b/asterixdb/asterix-cloud/src/main/java/org/apache/asterix/cloud/clients/aws/s3/S3CloudClient.java
@@ -145,8 +145,8 @@ @Override public byte[] readAllBytes(String bucket, String path) throws HyracksDataException { GetObjectRequest getReq = GetObjectRequest.builder().bucket(bucket).key(path).build(); - try { - ResponseInputStream<GetObjectResponse> stream = s3Client.getObject(getReq); + + try (ResponseInputStream<GetObjectResponse> stream = s3Client.getObject(getReq)) { return stream.readAllBytes(); } catch (NoSuchKeyException e) { return null;