[bugfix] Init BrokerQueryEventListener (apache#13995)

vvivekiyer · Sep 13, 2024 · f546add · f546add
1 parent de577bc
commit f546add
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...c/main/java/org/apache/pinot/spi/eventlistener/query/BrokerQueryEventListenerFactory.java b/...c/main/java/org/apache/pinot/spi/eventlistener/query/BrokerQueryEventListenerFactory.java
@@ -61,6 +61,7 @@ private static void initializeBrokerQueryEventListener(PinotConfiguration config
       _brokerQueryEventListener =
           (BrokerQueryEventListener) Class.forName(brokerQueryEventListenerClassName).getDeclaredConstructor()
               .newInstance();
+      _brokerQueryEventListener.init(config);
     } catch (Exception e) {
       throw new RuntimeException(e);
     }