From 86faa26b101dab9363aa0c345cc95d602bcdf392 Mon Sep 17 00:00:00 2001
From: Alexander Trushev <trushev.alex@gmail.com>
Date: Tue, 29 Nov 2022 20:44:41 +0700
Subject: [PATCH] [HUDI-5151] Fix bug with broken flink data skipping caused by
 ClassNotFoundException of InLineFileSystem (#7124)

---
 .../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 d923c592708c8..b36aa135a2cef 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
@@ -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(),