[fix](tvf) Support fs.defaultFS with postfix '/' #33202 (#33221)

bp #33202
apache · Apr 3, 2024 · 0a6803e · 0a6803e
1 parent dc641c3
commit 0a6803e
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/be/src/util/hdfs_util.cpp b/be/src/util/hdfs_util.cpp
@@ -45,6 +45,11 @@ Path convert_path(const Path& path, const std::string& namenode) {
     Path real_path(path);
     if (path.string().find(namenode) != std::string::npos) {
         std::string real_path_str = path.string().substr(namenode.size());
+        if (!real_path_str.starts_with("/")) {
+            // The real path must starts with "/"
+            // Or the hadoop client will add a prefix like "/user/hadoop".
+            real_path_str = "/" + real_path_str;
+        }
         real_path = real_path_str;
     }
     return real_path;