HADOOP-12891. S3AFileSystem should configure Multipart Copy threshold and chunk size. (Andrew Olson via stevel)

This commit is contained in:
Steve Loughran 2016-04-22 11:24:24 +01:00
parent adf937fbc0
commit 5df89f9a8a
3 changed files with 9 additions and 2 deletions

View File

@ -840,7 +840,10 @@
<property> <property>
<name>fs.s3a.multipart.threshold</name> <name>fs.s3a.multipart.threshold</name>
<value>2147483647</value> <value>2147483647</value>
<description>Threshold before uploads or copies use parallel multipart operations.</description> <description>How big (in bytes) to split upload or copy operations up into.
This also controls the partition size in renamed files, as rename() involves
copying the source file(s)
</description>
</property> </property>
<property> <property>

View File

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

View File

@ -315,7 +315,9 @@ this capability.
<property> <property>
<name>fs.s3a.multipart.size</name> <name>fs.s3a.multipart.size</name>
<value>104857600</value> <value>104857600</value>
<description>How big (in bytes) to split upload or copy operations up into.</description> <description>How big (in bytes) to split upload or copy operations up into.
This also controls the partition size in renamed files, as rename() involves
copying the source file(s)</description>
</property> </property>
<property> <property>