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

* fix bug for delete s3 dir and list s3 dir
FreeOnePlus · Oct 8, 2022 · c41892d · c41892d
1 parent a279d7e
commit c41892d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/be/src/io/fs/s3_file_system.cpp b/be/src/io/fs/s3_file_system.cpp
@@ -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);
 }