diff --git a/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/utils/HiveTableUtils.java b/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/utils/HiveTableUtils.java
index e4282db204b..7b9192ea645 100644
--- a/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/utils/HiveTableUtils.java
+++ b/seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/utils/HiveTableUtils.java
@@ -39,10 +39,12 @@ public static Table getTableInfo(ReadonlyConfig readonlyConfig) {
                     HiveConnectorErrorCode.HIVE_TABLE_NAME_ERROR, "Current table name is " + table);
         }
         HiveMetaStoreProxy hiveMetaStoreProxy = HiveMetaStoreProxy.getInstance(readonlyConfig);
-        Table tableInformation =
-                hiveMetaStoreProxy.getTable(tablePath.getDatabaseName(), tablePath.getTableName());
-        hiveMetaStoreProxy.close();
-        return tableInformation;
+        try {
+            return hiveMetaStoreProxy.getTable(
+                    tablePath.getDatabaseName(), tablePath.getTableName());
+        } finally {
+            hiveMetaStoreProxy.close();
+        }
     }
 
     public static FileFormat parseFileFormat(Table table) {