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(),