diff --git a/fe/fe-core/src/main/java/com/starrocks/common/Config.java b/fe/fe-core/src/main/java/com/starrocks/common/Config.java index a2ad355c186e01..77fcf2bdd1ec0e 100644 --- a/fe/fe-core/src/main/java/com/starrocks/common/Config.java +++ b/fe/fe-core/src/main/java/com/starrocks/common/Config.java @@ -1290,13 +1290,13 @@ public class Config extends ConfigBase { /** * If set to true, StarRocks will automatically synchronize hms metadata to the cache in fe. */ - @ConfField(mutable = true) + @ConfField public static boolean enable_hms_events_incremental_sync = false; /** * HMS polling interval in milliseconds. */ - @ConfField(mutable = true) + @ConfField public static int hms_events_polling_interval_ms = 5000; /** @@ -1314,7 +1314,7 @@ public class Config extends ConfigBase { /** * Num of thread to process events in parallel. */ - @ConfField(mutable = true) + @ConfField public static int hms_process_events_parallel_num = 4; /** diff --git a/fe/fe-core/src/main/java/com/starrocks/external/hive/events/MetastoreEventsProcessor.java b/fe/fe-core/src/main/java/com/starrocks/external/hive/events/MetastoreEventsProcessor.java index 5d323100dad9af..aec09938066047 100644 --- a/fe/fe-core/src/main/java/com/starrocks/external/hive/events/MetastoreEventsProcessor.java +++ b/fe/fe-core/src/main/java/com/starrocks/external/hive/events/MetastoreEventsProcessor.java @@ -214,8 +214,9 @@ private List getNextHMSEvents(String resourceName, if (response.getEvents().size() == 0) { return Collections.emptyList(); } - LOG.info(String.format("Received %d events. Start event id : %d. Last synced id : %d", - response.getEvents().size(), response.getEvents().get(0).getEventId(), lastSyncedEventId)); + LOG.info(String.format("Received %d events. Start event id : %d. Last synced id : %d on resource : %s", + response.getEvents().size(), response.getEvents().get(0).getEventId(), + lastSyncedEventId, resourceName)); if (filter == null) { return response.getEvents(); @@ -323,6 +324,8 @@ private void processEvents(List events, String resourceName) return; } + LOG.debug("Notification events {} to be processed", events); + if (Config.enable_hms_parallel_process_evens) { doExecuteWithPartialProgress(filteredEvents); } else {