[HUDI-7727] Avoid constructAbsolutePathInHadoopPath in hudi-common mo…

…dule (apache#11172)
AirToSupply · May 8, 2024 · ace3789 · ace3789
1 parent 91aa387
commit ace3789
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/hudi-common/src/main/java/org/apache/hudi/common/model/HoodieCommitMetadata.java b/hudi-common/src/main/java/org/apache/hudi/common/model/HoodieCommitMetadata.java
@@ -149,7 +149,7 @@ public List<String> getFullPathsByPartitionPath(String basePath, String partitio
     if (getPartitionToWriteStats().get(partitionPath) != null) {
       for (HoodieWriteStat stat : getPartitionToWriteStats().get(partitionPath)) {
         if ((stat.getFileId() != null)) {
-          String fullPath = FSUtils.constructAbsolutePathInHadoopPath(basePath, stat.getPath()).toString();
+          String fullPath = FSUtils.constructAbsolutePath(basePath, stat.getPath()).toString();
           fullPaths.add(fullPath);
         }
       }

diff --git a/...rc/main/java/org/apache/hudi/common/table/view/IncrementalTimelineSyncFileSystemView.java b/...rc/main/java/org/apache/hudi/common/table/view/IncrementalTimelineSyncFileSystemView.java
@@ -367,7 +367,7 @@ private void addCleanInstant(HoodieTimeline timeline, HoodieInstant instant) thr
       final String partitionPath = entry.getValue().getPartitionPath();
       List<String> fullPathList = entry.getValue().getSuccessDeleteFiles()
           .stream().map(fileName -> new StoragePath(FSUtils
-              .constructAbsolutePathInHadoopPath(basePath, partitionPath).toString(), fileName).toString())
+              .constructAbsolutePath(basePath, partitionPath), fileName).toString())
           .collect(Collectors.toList());
       removeFileSlicesForPartition(timeline, instant, entry.getKey(), fullPathList);
     });