diff --git a/core/src/main/java/com/datastrato/gravitino/catalog/BaseCatalog.java b/core/src/main/java/com/datastrato/gravitino/catalog/BaseCatalog.java index 1534823c2f1..9cb936b345d 100644 --- a/core/src/main/java/com/datastrato/gravitino/catalog/BaseCatalog.java +++ b/core/src/main/java/com/datastrato/gravitino/catalog/BaseCatalog.java @@ -118,11 +118,11 @@ public CatalogOperations ops() { private CatalogOperations createOps(Map conf) { String customCatalogOperationClass = conf.get(CATALOG_OPERATION_IMPL); return Optional.ofNullable(customCatalogOperationClass) - .map(className -> loadCustomerOps(className)) + .map(className -> loadCustomOps(className)) .orElse(newOps(conf)); } - private CatalogOperations loadCustomerOps(String className) { + private CatalogOperations loadCustomOps(String className) { ClassLoader classLoader = Thread.currentThread().getContextClassLoader(); try { // Class.forName use classloader of the caller class (BaseCatalog.class), it's global