This is an automated email from the ASF dual-hosted git repository.
codope pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 88db1ca974 [HUDI-5151] Fix bug with broken flink data skipping caused
by ClassNotFoundException of InLineFileSystem (#7124)
88db1ca974 is described below
commit 88db1ca9741bd83855aab86b7e977326dd87afa0
Author: Alexander Trushev <[email protected]>
AuthorDate: Tue Nov 29 20:44:41 2022 +0700
[HUDI-5151] Fix bug with broken flink data skipping caused by
ClassNotFoundException of InLineFileSystem (#7124)
---
.../org/apache/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 263b96343e..155e211141 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
@@ -192,7 +192,7 @@ public class HoodieHFileDataBlock extends HoodieDataBlock {
// 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(),