Skip to content

Commit 35d5eea

Browse files
author
Binbing Hou
committed
set chunk size to 256 MB for large files
1 parent 0808443 commit 35d5eea

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

genie-common-internal/src/main/java/com/netflix/genie/common/internal/aws/s3/S3TransferManagerFactory.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@
2323
import software.amazon.awssdk.services.s3.S3Uri;
2424
import software.amazon.awssdk.services.sts.auth.StsAssumeRoleCredentialsProvider;
2525
import software.amazon.awssdk.transfer.s3.S3TransferManager;
26-
2726
import java.net.URI;
2827
import java.util.UUID;
2928
import java.util.concurrent.ConcurrentHashMap;
@@ -36,6 +35,7 @@
3635
@Slf4j
3736
public class S3TransferManagerFactory {
3837

38+
private final static long MIN_PART_SIZE_IN_BYTES = 256 * 1024 * 1024L;
3939
private final S3ClientFactory s3ClientFactory;
4040
private final ConcurrentHashMap<S3ClientFactory.S3ClientKey, S3AsyncClient> asyncClientCache;
4141
private final ConcurrentHashMap<S3AsyncClient, S3TransferManager> transferManagerCache;
@@ -116,6 +116,7 @@ private S3AsyncClient buildS3AsyncClient(final S3ClientFactory.S3ClientKey s3Cli
116116
.region(s3ClientKey.getRegion())
117117
.credentialsProvider(credentialsProvider)
118118
.multipartEnabled(true)
119+
.multipartConfiguration(configBuilder -> configBuilder.minimumPartSizeInBytes(MIN_PART_SIZE_IN_BYTES))
119120
.build();
120121
}
121122

0 commit comments

Comments
 (0)