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 b5de3f8 Disabling small file optimization for s3 outgoing
b5de3f8 is described below
commit b5de3f802878c9d11b16a92b4be069565524eff5
Author: DImuthuUpe <[email protected]>
AuthorDate: Wed Aug 30 19:12:21 2023 +0530
Disabling small file optimization for s3 outgoing
---
.../org/apache/airavata/mft/transport/s3/S3OutgoingConnector.java | 8 ++++----
1 file changed, 4 insertions(+), 4 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 d9f1844..6cc17d4 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
@@ -70,15 +70,15 @@ public class S3OutgoingConnector implements
OutgoingChunkedConnector {
s3Client = S3Util.getInstance().leaseS3Client(s3Secret, s3Storage);
- if (cc.getChunkSize() < cc.getMetadata().getFile().getResourceSize()) {
+ //if (cc.getChunkSize() <
cc.getMetadata().getFile().getResourceSize()) {
InitiateMultipartUploadRequest initRequest = new
InitiateMultipartUploadRequest(s3Storage.getBucketName(),
resourcePath);
initResponse = s3Client.initiateMultipartUpload(initRequest);
logger.info("Initialized multipart upload for file {} in bucket
{}",
resourcePath, s3Storage.getBucketName());
- } else {
- logger.info("Using non-multipart upload for file {} in bucket {}",
resourcePath, s3Storage.getBucketName());
- }
+ //} else {
+ // logger.info("Using non-multipart upload for file {} in bucket
{}", resourcePath, s3Storage.getBucketName());
+ //}
}
@Override