(pinot) branch master updated: [bugfix] Init BrokerQueryEventListener (#13995)

[ankitsultana]

This is an automated email from the ASF dual-hosted git repository.

ankitsultana pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git


The following commit(s) were added to refs/heads/master by this push:
     new f546add468 [bugfix] Init BrokerQueryEventListener (#13995)
f546add468 is described below

commit f546add468f2485218e034b8b22e64b69d3faa54
Author: Pratik Tibrewal <tibrewalpra...@uber.com>
AuthorDate: Fri Sep 13 17:59:38 2024 +0530

    [bugfix] Init BrokerQueryEventListener (#13995)
---
 .../pinot/spi/eventlistener/query/BrokerQueryEventListenerFactory.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/pinot-spi/src/main/java/org/apache/pinot/spi/eventlistener/query/BrokerQueryEventListenerFactory.java
 
b/pinot-spi/src/main/java/org/apache/pinot/spi/eventlistener/query/BrokerQueryEventListenerFactory.java
index 980eb9e5e2..add6703a25 100644
--- 
a/pinot-spi/src/main/java/org/apache/pinot/spi/eventlistener/query/BrokerQueryEventListenerFactory.java
+++ 
b/pinot-spi/src/main/java/org/apache/pinot/spi/eventlistener/query/BrokerQueryEventListenerFactory.java
@@ -61,6 +61,7 @@ public class BrokerQueryEventListenerFactory {
       _brokerQueryEventListener =
           (BrokerQueryEventListener) 
Class.forName(brokerQueryEventListenerClassName).getDeclaredConstructor()
               .newInstance();
+      _brokerQueryEventListener.init(config);
     } catch (Exception e) {
       throw new RuntimeException(e);
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org