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