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

…tFoundException of InLineFileSystem (#7124)
apache · Nov 29, 2022 · 88db1ca · 88db1ca
1 parent fe43e6f
commit 88db1ca
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
@@ -192,7 +192,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(),