(hudi) branch master updated: [HUDI-7727] Avoid constructAbsolutePathInHadoopPath in hudi-common module (#11172)

[yihua]

This is an automated email from the ASF dual-hosted git repository.

yihua pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new ace3789e2d5 [HUDI-7727] Avoid constructAbsolutePathInHadoopPath in 
hudi-common module (#11172)
ace3789e2d5 is described below

commit ace3789e2d584da77fa1aee02b4ab5fa12410870
Author: Y Ethan Guo <ethan.guoyi...@gmail.com>
AuthorDate: Tue May 7 23:01:52 2024 -0700

    [HUDI-7727] Avoid constructAbsolutePathInHadoopPath in hudi-common module 
(#11172)
---
 .../main/java/org/apache/hudi/common/model/HoodieCommitMetadata.java    | 2 +-
 .../hudi/common/table/view/IncrementalTimelineSyncFileSystemView.java   | 2 +-
 2 files changed, 2 insertions(+), 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
index fbd21477965..31c39407ad7 100644
--- 
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 class HoodieCommitMetadata implements Serializable {
     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/hudi-common/src/main/java/org/apache/hudi/common/table/view/IncrementalTimelineSyncFileSystemView.java
 
b/hudi-common/src/main/java/org/apache/hudi/common/table/view/IncrementalTimelineSyncFileSystemView.java
index dead4f0c726..7497cb8a496 100644
--- 
a/hudi-common/src/main/java/org/apache/hudi/common/table/view/IncrementalTimelineSyncFileSystemView.java
+++ 
b/hudi-common/src/main/java/org/apache/hudi/common/table/view/IncrementalTimelineSyncFileSystemView.java
@@ -367,7 +367,7 @@ public abstract class IncrementalTimelineSyncFileSystemView 
extends AbstractTabl
       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);
     });