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

zhangyue19921010 pushed a commit to branch HUDI-9239
in repository https://gitbox.apache.org/repos/asf/hudi.git

commit cd164f612b0740446385572e55cce394a76e4cb4
Author: YueZhang <zhangyue921...@163.com>
AuthorDate: Fri Mar 28 13:00:29 2025 +0800

    Fix the bug of Spark Cache not releasing cleanly
---
 hudi-common/src/main/java/org/apache/hudi/common/data/HoodieData.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/hudi-common/src/main/java/org/apache/hudi/common/data/HoodieData.java 
b/hudi-common/src/main/java/org/apache/hudi/common/data/HoodieData.java
index e65a8f426bd..6a00341d645 100644
--- a/hudi-common/src/main/java/org/apache/hudi/common/data/HoodieData.java
+++ b/hudi-common/src/main/java/org/apache/hudi/common/data/HoodieData.java
@@ -23,6 +23,7 @@ import org.apache.hudi.common.engine.HoodieEngineContext;
 import org.apache.hudi.common.function.SerializableFunction;
 import org.apache.hudi.common.function.SerializablePairFunction;
 import org.apache.hudi.common.util.collection.Pair;
+import org.apache.hudi.storage.StoragePath;
 
 import java.io.Serializable;
 import java.util.Iterator;
@@ -227,7 +228,7 @@ public interface HoodieData<T> extends Serializable {
   class HoodieDataCacheKey implements Serializable {
 
     public static HoodieDataCacheKey of(String basePath, String instantTime) {
-      return new HoodieDataCacheKey(basePath, instantTime);
+      return new HoodieDataCacheKey(new StoragePath(basePath).toString(), 
instantTime);
     }
 
     private final String basePath;

Reply via email to