From f546add468f2485218e034b8b22e64b69d3faa54 Mon Sep 17 00:00:00 2001 From: Pratik Tibrewal Date: Fri, 13 Sep 2024 17:59:38 +0530 Subject: [PATCH] [bugfix] Init BrokerQueryEventListener (#13995) --- .../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 980eb9e5e2b..add6703a251 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 @@ private static void initializeBrokerQueryEventListener(PinotConfiguration config _brokerQueryEventListener = (BrokerQueryEventListener) Class.forName(brokerQueryEventListenerClassName).getDeclaredConstructor() .newInstance(); + _brokerQueryEventListener.init(config); } catch (Exception e) { throw new RuntimeException(e); }