diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalCatalog.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalCatalog.java index ceb4755b2c5f12..0711775963e7ec 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalCatalog.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/hive/HMSExternalCatalog.java @@ -155,9 +155,6 @@ protected void initLocalObjectsImpl() { @Override public synchronized void resetToUninitialized(boolean invalidCache) { super.resetToUninitialized(invalidCache); - if (metadataOps != null) { - metadataOps.close(); - } } @Override @@ -166,8 +163,13 @@ public void onClose() { if (null != fileSystemExecutor) { fileSystemExecutor.shutdown(); } + if (null != metadataOps) { + metadataOps.close(); + metadataOps = null; + } if (null != icebergMetadataOps) { icebergMetadataOps.close(); + icebergMetadataOps = null; } }