From 1446e65992b10a1f354d9d158bd50e54ea9e4c7f Mon Sep 17 00:00:00 2001 From: "Ansari, Mujammil" Date: Fri, 20 Sep 2024 14:46:58 +0530 Subject: [PATCH] Use correct s3 client based on bucket for import Signed-off-by: Ansari, Mujammil --- .../here/xyz/jobs/steps/impl/transport/ImportFilesToSpace.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/xyz-jobs/xyz-job-steps/src/main/java/com/here/xyz/jobs/steps/impl/transport/ImportFilesToSpace.java b/xyz-jobs/xyz-job-steps/src/main/java/com/here/xyz/jobs/steps/impl/transport/ImportFilesToSpace.java index e55e0ac78..9babcc4da 100644 --- a/xyz-jobs/xyz-job-steps/src/main/java/com/here/xyz/jobs/steps/impl/transport/ImportFilesToSpace.java +++ b/xyz-jobs/xyz-job-steps/src/main/java/com/here/xyz/jobs/steps/impl/transport/ImportFilesToSpace.java @@ -370,7 +370,7 @@ private void syncExecution() throws WebClientException, SQLException, TooManyRes */ private int syncWriteFileToSpace(Input input, long newVersion) throws IOException, WebClientException, SQLException, TooManyResourcesClaimed { - final S3Client s3Client = S3Client.getInstance(); + final S3Client s3Client = S3Client.getInstance(input.getS3Bucket()); InputStream inputStream = s3Client.streamObjectContent(input.getS3Key()); if (input.isCompressed())