Skip to content

Commit

Permalink
[Enhancement](multi-catalog) Speed up consume rate of hms event.
Browse files Browse the repository at this point in the history
  • Loading branch information
wangxiangyu committed Nov 28, 2023
1 parent 9b7a0ef commit 197c7ae
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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),
Expand Down

0 comments on commit 197c7ae

Please sign in to comment.