From 197c7aee0d85654bb1eb1ebab4fbe0f44b49e4aa Mon Sep 17 00:00:00 2001 From: wangxiangyu Date: Tue, 28 Nov 2023 14:50:43 +0800 Subject: [PATCH] [Enhancement](multi-catalog) Speed up consume rate of hms event. --- .../java/org/apache/doris/datasource/HMSExternalCatalog.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/HMSExternalCatalog.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/HMSExternalCatalog.java index 2f5735d888e1b6..cd677a623c918a 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/datasource/HMSExternalCatalog.java +++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/HMSExternalCatalog.java @@ -243,7 +243,7 @@ public NotificationEventResponse getNextEventResponse(HMSExternalCatalog hmsExte if (!Env.getCurrentEnv().isMaster()) { // return if lastSyncedEventId of slave FE is lower than masterLastSyncedEventId if (lastSyncedEventId == masterLastSyncedEventId) { - return null; + return null; } // For slave FE nodes, only fetch events which id is lower than masterLastSyncedEventId maxEventSize = Math.min((int) (masterLastSyncedEventId - lastSyncedEventId),