Fix bug in s3 delete directory (#11344)

2022-07-30 18:31:32 +08:00
parent 0497d58943
commit fb90586122
1 changed files with 3 additions and 0 deletions
--- a/be/src/io/fs/s3_file_system.cpp
+++ b/be/src/io/fs/s3_file_system.cpp
@ -174,6 +174,9 @@ Status S3FileSystem::delete_directory(const Path& path) {

    Aws::S3::Model::ListObjectsV2Request request;
    auto prefix = get_key(path);
+    if (!prefix.empty() && prefix.back() != '/') {
+        prefix.push_back('/');
+    }
    request.WithBucket(_s3_conf.bucket).WithPrefix(prefix);

    Aws::S3::Model::DeleteObjectsRequest delete_request;