You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by sa...@apache.org on 2022/12/13 08:04:49 UTC
[hudi] 14/22: [HUDI-5151] Fix bug with broken flink data skipping caused by ClassNotFoundException of InLineFileSystem (#7124)
This is an automated email from the ASF dual-hosted git repository.
satish pushed a commit to branch release-0.12.2
in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 0dda39d4c539be0b72907c6ad7c469e77709dbe8
Author: Alexander Trushev <tr...@gmail.com>
AuthorDate: Tue Nov 29 20:44:41 2022 +0700
[HUDI-5151] Fix bug with broken flink data skipping caused by ClassNotFoundException of InLineFileSystem (#7124)
---
.../org/apache/hudi/common/table/log/block/HoodieHFileDataBlock.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieHFileDataBlock.java b/hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieHFileDataBlock.java
index 263b96343e6..155e2111419 100644
--- a/hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieHFileDataBlock.java
+++ b/hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieHFileDataBlock.java
@@ -192,7 +192,7 @@ public class HoodieHFileDataBlock extends HoodieDataBlock {
// is appropriately carried over
Configuration inlineConf = new Configuration(blockContentLoc.getHadoopConf());
inlineConf.set("fs." + InLineFileSystem.SCHEME + ".impl", InLineFileSystem.class.getName());
- inlineConf.setClassLoader(Thread.currentThread().getContextClassLoader());
+ inlineConf.setClassLoader(InLineFileSystem.class.getClassLoader());
Path inlinePath = InLineFSUtils.getInlineFilePath(
blockContentLoc.getLogFile().getPath(),