diff --git a/hudi-common/src/main/java/org/apache/hudi/common/util/ReflectionUtils.java b/hudi-common/src/main/java/org/apache/hudi/common/util/ReflectionUtils.java
index bb30b2a1f..22bec2e63 100644
--- a/hudi-common/src/main/java/org/apache/hudi/common/util/ReflectionUtils.java
+++ b/hudi-common/src/main/java/org/apache/hudi/common/util/ReflectionUtils.java
@@ -50,7 +50,8 @@ public class ReflectionUtils {
   public static Class<?> getClass(String clazzName) {
     if (!clazzCache.containsKey(clazzName)) {
       try {
-        Class<?> clazz = Class.forName(clazzName);
+        Class<?> clazz = Class.forName(clazzName, true,
+                Thread.currentThread().getContextClassLoader());
         clazzCache.put(clazzName, clazz);
       } catch (ClassNotFoundException e) {
         throw new HoodieException("Unable to load class", e);