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 cdff7aeaf9377..26c9db5a15fb7 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 @@ -196,6 +196,7 @@ protected ClosableIterator lookupRecords(List keys) throw // is appropriately carried over Configuration inlineConf = new Configuration(blockContentLoc.getHadoopConf()); inlineConf.set("fs." + InLineFileSystem.SCHEME + ".impl", InLineFileSystem.class.getName()); + inlineConf.setClassLoader(Thread.currentThread().getContextClassLoader()); Path inlinePath = InLineFSUtils.getInlineFilePath( blockContentLoc.getLogFile().getPath(),