|
@@ -260,6 +260,8 @@ public class S3AFileSystem extends FileSystem {
|
|
|
TransferManagerConfiguration transferConfiguration = new TransferManagerConfiguration();
|
|
|
transferConfiguration.setMinimumUploadPartSize(partSize);
|
|
|
transferConfiguration.setMultipartUploadThreshold(multiPartThreshold);
|
|
|
+ transferConfiguration.setMultipartCopyPartSize(partSize);
|
|
|
+ transferConfiguration.setMultipartCopyThreshold(multiPartThreshold);
|
|
|
|
|
|
transfers = new TransferManager(s3, threadPoolExecutor);
|
|
|
transfers.setConfiguration(transferConfiguration);
|