[HUDI-5151] Fix bug with broken flink data skipping caused by ClassNo…

…tFoundException of InLineFileSystem (apache#7124)
onehouseinc · Dec 14, 2022 · a583f8c · a583f8c
1 parent fa743f5
commit a583f8c
Showing 1 changed file with 1 addition and 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
@@ -194,7 +194,7 @@ protected ClosableIterator<IndexedRecord> lookupRecords(List<String> keys, boole
     //       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(),