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 <[email protected]> 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(),
