database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](remote)fix bug for delete s3 dir and list s3 dir (#12918)

Browse Source 
* fix bug for delete s3 dir and list s3 dir
This commit is contained in:
pengxiangyu
2022-09-27 09:54:37 +08:00
committed by GitHub
parent 72b909b5e8
commit e040dccbec
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
be/src/io/fs/s3_file_system.cpp
View File

@ -51,6 +51,9 @@ S3FileSystem::S3FileSystem(S3Conf s3_conf, ResourceId resource_id)
fmt::format("{}/{}/{}", s3_conf.endpoint, s3_conf.bucket, s3_conf.prefix),
std::move(resource_id), FileSystemType::S3),
_s3_conf(std::move(s3_conf)) {
if (_s3_conf.prefix.size() > 0 && _s3_conf.prefix[0] == '/') {
_s3_conf.prefix = _s3_conf.prefix.substr(1);
}
_executor = Aws::MakeShared<Aws::Utils::Threading::PooledThreadExecutor>(
resource_id.c_str(), config::s3_transfer_executor_pool_size);
}