[HUDI-4002] Fix ClassCastException of HoodieWrapperFileSystem

yihua · yihua · commit 2a8cb2cb19f2 · 2022-04-29T18:21:29.000-07:00
diff --git a/hudi-common/src/main/java/org/apache/hudi/common/fs/FSUtils.java b/hudi-common/src/main/java/org/apache/hudi/common/fs/FSUtils.java
@@ -633,6 +633,7 @@ public static Configuration registerFileSystem(Path file, Configuration conf) {
     String scheme = FSUtils.getFs(file.toString(), conf).getScheme();
     returnConf.set("fs." + HoodieWrapperFileSystem.getHoodieScheme(scheme) + ".impl",
         HoodieWrapperFileSystem.class.getName());
+    returnConf.setClassLoader(Thread.currentThread().getContextClassLoader());
     return returnConf;
   }
 

Original file line number	Diff line number	Diff line change
`@@ -633,6 +633,7 @@ public static Configuration registerFileSystem(Path file, Configuration conf) {`
`633`	`633`	`String scheme = FSUtils.getFs(file.toString(), conf).getScheme();`
`634`	`634`	`returnConf.set("fs." + HoodieWrapperFileSystem.getHoodieScheme(scheme) + ".impl",`
`635`	`635`	`HoodieWrapperFileSystem.class.getName());`
	`636`	`+ returnConf.setClassLoader(Thread.currentThread().getContextClassLoader());`
`636`	`637`	`return returnConf;`
`637`	`638`	`}`
`638`	`639`