[BugFix] Fix an issue that can’t enable automatic incremental update …

…for a single Hive catalog.
StarRocks · Jun 10, 2024 · 63f6792 · 63f6792
1 parent c349de8
commit 63f6792
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 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
@@ -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
@@ -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();