Use correct s3 client based on bucket for import

Signed-off-by: Ansari, Mujammil <[email protected]>
heremaps · Sep 20, 2024 · 1446e65 · 1446e65
1 parent 8bf4778
commit 1446e65
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...yz-job-steps/src/main/java/com/here/xyz/jobs/steps/impl/transport/ImportFilesToSpace.java b/...yz-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())