From 31c78a2f536585d4d3c8aa5e102c9b57e101db7a Mon Sep 17 00:00:00 2001
From: edwinhzhang <edwinhzhang@tencent.com>
Date: Mon, 10 Jun 2024 12:04:51 +0800
Subject: [PATCH] =?UTF-8?q?[BugFix]=20Fix=20an=20issue=20that=20can?=
 =?UTF-8?q?=E2=80=99t=20enable=20automatic=20incremental=20update=20for=20?=
 =?UTF-8?q?a=20single=20Hive=20catalog.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Signed-off-by: edwinhzhang <edwinhzhang@tencent.com>
---
 .../connector/hive/events/MetastoreEventsProcessor.java       | 3 +++
 .../src/main/java/com/starrocks/server/GlobalStateMgr.java    | 4 +---
 2 files changed, 4 insertions(+), 3 deletions(-)

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 52007015a9d9b..6d80b611a4f46 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 e31ecce0ff1b9..89767c64efd4e 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();