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;