FANNG1 commented on code in PR #6891:
URL: https://github.com/apache/gravitino/pull/6891#discussion_r2041489994
##########
core/src/main/java/org/apache/gravitino/listener/EventBus.java:
##########
@@ -47,6 +50,11 @@ public class EventBus {
*/
public EventBus(List<EventListenerPlugin> eventListeners) {
this.eventListeners = eventListeners;
+ this.asyncQueueListeners =
Review Comment:
`eventListeners` holds all event listeners include sync and async listeners
while `asyncQueueListeners` includes async listeners only. The reason why we
add `asyncQueueListeners` is to check the high watermark status of the async
event queue to back pressure the linage sources.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@gravitino.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
