loadSchema

apache · Jan 2, 2025 · 5481807 · 5481807
1 parent 3850237
commit 5481807
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/core/src/main/java/org/apache/gravitino/catalog/SchemaOperationDispatcher.java b/core/src/main/java/org/apache/gravitino/catalog/SchemaOperationDispatcher.java
@@ -173,8 +173,7 @@ public Schema createSchema(NameIdentifier ident, String comment, Map<String, Str
   @Override
   public Schema loadSchema(NameIdentifier ident) throws NoSuchSchemaException {
     // Load the schema and check if this schema is already imported.
-    EntityCombinedSchema schema = internalLoadSchema(ident);
-    //    TreeLockUtils.doWithTreeLock(ident, LockType.READ, () -> internalLoadSchema(ident));
+    EntityCombinedSchema schema = TreeLockUtils.doWithTreeLock(ident, LockType.READ, () -> internalLoadSchema(ident));
 
     if (!schema.imported()) {
       TreeLockUtils.doWithTreeLock(
@@ -278,7 +277,7 @@ public Schema alterSchema(NameIdentifier ident, SchemaChange... changes)
   public boolean dropSchema(NameIdentifier ident, boolean cascade) throws NonEmptySchemaException {
     NameIdentifier catalogIdent = getCatalogIdentifier(ident);
     return TreeLockUtils.doWithTreeLock(
-        ident,
+        catalogIdent,
         LockType.WRITE,
         () -> {
           boolean droppedFromCatalog =