Skip to content

Commit 4a0b7fd

Browse files
committed
Do not create the AwsTransferManager object if is not enabled.
1 parent dcd6453 commit 4a0b7fd

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

cloud/aws/aws_env.cc

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -428,7 +428,7 @@ AwsEnv::AwsEnv(Env* underlying_env, const CloudEnvOptions& _cloud_env_options,
428428
creds ? "[given]" : "[not given]");
429429

430430
base_env_ = underlying_env;
431-
431+
432432
// TODO: support buckets being in different regions
433433
if (!SrcMatchesDest() && HasSrcBucket() && HasDestBucket()) {
434434
if (cloud_env_options.src_bucket.GetRegion() == cloud_env_options.dest_bucket.GetRegion()) {
@@ -474,8 +474,11 @@ AwsEnv::AwsEnv(Env* underlying_env, const CloudEnvOptions& _cloud_env_options,
474474
transferManagerConfig.putObjectTemplate);
475475
SetEncryptionParameters(
476476
cloud_env_options, transferManagerConfig.createMultipartUploadTemplate);
477-
awsTransferManager_ =
478-
Aws::Transfer::TransferManager::Create(transferManagerConfig);
477+
478+
if (cloud_env_options.use_aws_transfer_manager) {
479+
awsTransferManager_ =
480+
Aws::Transfer::TransferManager::Create(transferManagerConfig);
481+
}
479482
}
480483

481484
// create dest bucket if specified
@@ -1974,4 +1977,3 @@ std::string AwsEnv::GetWALCacheDir() {
19741977
#pragma GCC diagnostic pop
19751978
#endif // USE_AWS
19761979
} // namespace rocksdb
1977-

0 commit comments

Comments
 (0)