diff --git a/fe/fe-core/src/main/java/com/starrocks/connector/hive/events/MetastoreEventsProcessor.java b/fe/fe-core/src/main/java/com/starrocks/connector/hive/events/MetastoreEventsProcessor.java
index 52007015a9d9bd..6d80b611a4f46d 100644
--- a/fe/fe-core/src/main/java/com/starrocks/connector/hive/events/MetastoreEventsProcessor.java
+++ b/fe/fe-core/src/main/java/com/starrocks/connector/hive/events/MetastoreEventsProcessor.java
@@ -211,6 +211,9 @@ private void processEvents(List<NotificationEvent> events, String catalogName) {
     @Override
     protected void runAfterCatalogReady() {
         List<String> catalogs = Lists.newArrayList(cacheUpdateProcessors.keySet());
+        if (catalogs.isEmpty()) {
+            return;
+        }
         int resourceCatalogNum = (int) cacheUpdateProcessors.keySet().stream()
                 .filter(CatalogMgr.ResourceMappingCatalog::isResourceMappingCatalog).count();
         int catalogNum = cacheUpdateProcessors.size() - resourceCatalogNum;
diff --git a/fe/fe-core/src/main/java/com/starrocks/server/GlobalStateMgr.java b/fe/fe-core/src/main/java/com/starrocks/server/GlobalStateMgr.java
index e31ecce0ff1b98..89767c64efd4e3 100644
--- a/fe/fe-core/src/main/java/com/starrocks/server/GlobalStateMgr.java
+++ b/fe/fe-core/src/main/java/com/starrocks/server/GlobalStateMgr.java
@@ -1357,9 +1357,7 @@ private void startAllNodeTypeDaemonThreads() {
         // ES state store
         esRepository.start();
 
-        if (Config.enable_hms_events_incremental_sync) {
-            metastoreEventsProcessor.start();
-        }
+        metastoreEventsProcessor.start();
 
         connectorTableMetadataProcessor.start();