lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-2219] Fix NPE of HoodieConfig (#3342)

Browse Source
This commit is contained in:
Danny Chan
2021-07-27 15:18:05 +08:00
committed by GitHub
parent 9d2a65a6a6
commit ab2e0d0ba2
1 changed files with 11 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
hudi-common/src/main/java/org/apache/hudi/common/util/ReflectionUtils.java
View File

@@ -45,19 +45,21 @@ public class ReflectionUtils {
private static final Logger LOG = LogManager.getLogger(ReflectionUtils.class); private static final Logger LOG = LogManager.getLogger(ReflectionUtils.class);
private static Map<String, Class<?>> clazzCache = new HashMap<>(); private static final Map<String, Class<?>> CLAZZ_CACHE = new HashMap<>();
public static Class<?> getClass(String clazzName) { public static Class<?> getClass(String clazzName) {
if (!clazzCache.containsKey(clazzName)) { synchronized (CLAZZ_CACHE) {
try { if (!CLAZZ_CACHE.containsKey(clazzName)) {
Class<?> clazz = Class.forName(clazzName, true, try {
Thread.currentThread().getContextClassLoader()); Class<?> clazz = Class.forName(clazzName, true,
clazzCache.put(clazzName, clazz); Thread.currentThread().getContextClassLoader());
} catch (ClassNotFoundException e) { CLAZZ_CACHE.put(clazzName, clazz);
throw new HoodieException("Unable to load class", e); } catch (ClassNotFoundException e) {
throw new HoodieException("Unable to load class", e);
}
} }
} }
return clazzCache.get(clazzName); return CLAZZ_CACHE.get(clazzName);
} }
public static <T> T loadClass(String fqcn) { public static <T> T loadClass(String fqcn) {