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

…tFoundException of InLineFileSystem
apache · Nov 3, 2022 · 8760839 · 8760839
1 parent 0d7d3aa
commit 8760839
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(),