[airavata-mft] branch master updated: Fixing complete logic for S3 non multipart uploads

[dimuthuupe]

This is an automated email from the ASF dual-hosted git repository.

dimuthuupe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata-mft.git


The following commit(s) were added to refs/heads/master by this push:
     new fa14a25  Fixing complete logic for S3 non multipart uploads
fa14a25 is described below

commit fa14a256f1987a320b589b919738c4615ab919a5
Author: DImuthuUpe <dimuthu.upeks...@gmail.com>
AuthorDate: Wed Aug 30 17:56:50 2023 +0530

    Fixing complete logic for S3 non multipart uploads
---
 .../airavata/mft/transport/s3/S3OutgoingConnector.java       | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git 
a/transport/s3-transport/src/main/java/org/apache/airavata/mft/transport/s3/S3OutgoingConnector.java
 
b/transport/s3-transport/src/main/java/org/apache/airavata/mft/transport/s3/S3OutgoingConnector.java
index 6dfa022..d9f1844 100644
--- 
a/transport/s3-transport/src/main/java/org/apache/airavata/mft/transport/s3/S3OutgoingConnector.java
+++ 
b/transport/s3-transport/src/main/java/org/apache/airavata/mft/transport/s3/S3OutgoingConnector.java
@@ -130,11 +130,13 @@ public class S3OutgoingConnector implements 
OutgoingChunkedConnector {
 
     @Override
     public void complete() throws Exception {
-        CompleteMultipartUploadRequest compRequest = new 
CompleteMultipartUploadRequest(s3Storage.getBucketName(),
-                resourcePath, initResponse.getUploadId(), partETags);
-        s3Client.completeMultipartUpload(compRequest);
-        logger.info("Completing the upload for file {} in bucket {}", 
resourcePath,
-                s3Storage.getBucketName());
+
+        if (initResponse != null) {
+            CompleteMultipartUploadRequest compRequest = new 
CompleteMultipartUploadRequest(s3Storage.getBucketName(),
+                    resourcePath, initResponse.getUploadId(), partETags);
+            s3Client.completeMultipartUpload(compRequest);
+        }
+        logger.info("Completed the upload for file {} in bucket {}", 
resourcePath, s3Storage.getBucketName());
     }
 
     @Override