diff --git a/fe/fe-core/src/main/java/com/starrocks/connector/hive/HiveConnectorInternalMgr.java b/fe/fe-core/src/main/java/com/starrocks/connector/hive/HiveConnectorInternalMgr.java
index 0758a2ba0f170f..803b86834fcb88 100644
--- a/fe/fe-core/src/main/java/com/starrocks/connector/hive/HiveConnectorInternalMgr.java
+++ b/fe/fe-core/src/main/java/com/starrocks/connector/hive/HiveConnectorInternalMgr.java
@@ -49,7 +49,7 @@ public class HiveConnectorInternalMgr {
     private final CachingRemoteFileConf remoteFileConf;
 
     private ExecutorService refreshHiveMetastoreExecutor;
-    private ExecutorService refreshExternalTableExecutor;
+    private ExecutorService refreshHiveExternalTableExecutor;
     private ExecutorService refreshRemoteFileExecutor;
     private ExecutorService pullRemoteFileExecutor;
     private ExecutorService updateRemoteFilesExecutor;
@@ -101,8 +101,8 @@ public void shutdown() {
         if (enableMetastoreCache && refreshHiveMetastoreExecutor != null) {
             refreshHiveMetastoreExecutor.shutdown();
         }
-        if (enableMetastoreCache && refreshExternalTableExecutor != null) {
-            refreshExternalTableExecutor.shutdown();
+        if (enableMetastoreCache && refreshHiveExternalTableExecutor != null) {
+            refreshHiveExternalTableExecutor.shutdown();
         }
         if (enableRemoteFileCache && refreshRemoteFileExecutor != null) {
             refreshRemoteFileExecutor.shutdown();
@@ -122,12 +122,12 @@ public IHiveMetastore createHiveMetastore() {
         } else {
             refreshHiveMetastoreExecutor = Executors.newCachedThreadPool(
                     new ThreadFactoryBuilder().setNameFormat("hive-metastore-refresh-%d").build());
-            refreshExternalTableExecutor = Executors.newCachedThreadPool(
+            refreshHiveExternalTableExecutor = Executors.newCachedThreadPool(
                     new ThreadFactoryBuilder().setNameFormat("hive-external-table-refresh-%d").build());
             baseHiveMetastore = CachingHiveMetastore.createCatalogLevelInstance(
                     hiveMetastore,
                     new ReentrantExecutor(refreshHiveMetastoreExecutor, hmsConf.getCacheRefreshThreadMaxNum()),
-                    new ReentrantExecutor(refreshExternalTableExecutor, hmsConf.getCacheRefreshThreadMaxNum()),
+                    new ReentrantExecutor(refreshHiveExternalTableExecutor, hmsConf.getCacheRefreshThreadMaxNum()),
                     hmsConf.getCacheTtlSec(),
                     enableHmsEventsIncrementalSync ? NEVER_REFRESH : hmsConf.getCacheRefreshIntervalSec(),
                     hmsConf.getCacheMaxNum(),
diff --git a/fe/fe-core/src/main/java/com/starrocks/connector/hudi/HudiConnectorInternalMgr.java b/fe/fe-core/src/main/java/com/starrocks/connector/hudi/HudiConnectorInternalMgr.java
index e5d2331031200c..088c3f1a746e6d 100644
--- a/fe/fe-core/src/main/java/com/starrocks/connector/hudi/HudiConnectorInternalMgr.java
+++ b/fe/fe-core/src/main/java/com/starrocks/connector/hudi/HudiConnectorInternalMgr.java
@@ -50,7 +50,7 @@ public class HudiConnectorInternalMgr {
     private CachingRemoteFileConf remoteFileConf;
 
     private ExecutorService refreshHiveMetastoreExecutor;
-    private ExecutorService refreshExternalTableExecutor;
+    private ExecutorService refreshHudiExternalTableExecutor;
     private ExecutorService refreshRemoteFileExecutor;
     private ExecutorService pullRemoteFileExecutor;
 
@@ -95,8 +95,8 @@ public void shutdown() {
         if (enableMetastoreCache && refreshHiveMetastoreExecutor != null) {
             refreshHiveMetastoreExecutor.shutdown();
         }
-        if (enableMetastoreCache && refreshExternalTableExecutor != null) {
-            refreshExternalTableExecutor.shutdown();
+        if (enableMetastoreCache && refreshHudiExternalTableExecutor != null) {
+            refreshHudiExternalTableExecutor.shutdown();
         }
         if (enableRemoteFileCache && refreshRemoteFileExecutor != null) {
             refreshRemoteFileExecutor.shutdown();
@@ -116,12 +116,12 @@ public IHiveMetastore createHiveMetastore() {
         } else {
             refreshHiveMetastoreExecutor = Executors.newCachedThreadPool(
                     new ThreadFactoryBuilder().setNameFormat("hive-metastore-refresh-%d").build());
-            refreshExternalTableExecutor = Executors.newCachedThreadPool(
-                    new ThreadFactoryBuilder().setNameFormat("hive-external-table-refresh-%d").build());
+            refreshHudiExternalTableExecutor = Executors.newCachedThreadPool(
+                    new ThreadFactoryBuilder().setNameFormat("hudi-external-table-refresh-%d").build());
             baseHiveMetastore = CachingHiveMetastore.createCatalogLevelInstance(
                     hiveMetastore,
                     new ReentrantExecutor(refreshHiveMetastoreExecutor, hmsConf.getCacheRefreshThreadMaxNum()),
-                    new ReentrantExecutor(refreshExternalTableExecutor, hmsConf.getCacheRefreshThreadMaxNum()),
+                    new ReentrantExecutor(refreshHudiExternalTableExecutor, hmsConf.getCacheRefreshThreadMaxNum()),
                     hmsConf.getCacheTtlSec(),
                     hmsConf.getCacheRefreshIntervalSec(),
                     hmsConf.getCacheMaxNum(),