(pinot) branch master updated: Log when table to broker list map is refreshed (#13766)

[gortiz]

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

gortiz 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 a8a9fa8822 Log when table to broker list map is refreshed (#13766)
a8a9fa8822 is described below

commit a8a9fa8822065ad4d955a188c745f8d7dce749bd
Author: soumitra-st <127247229+soumitra...@users.noreply.github.com>
AuthorDate: Tue Aug 6 23:48:34 2024 -0700

    Log when table to broker list map is refreshed (#13766)
---
 .../src/main/java/org/apache/pinot/client/DynamicBrokerSelector.java  | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/DynamicBrokerSelector.java
 
b/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/DynamicBrokerSelector.java
index 84b37a418f..b349423d83 100644
--- 
a/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/DynamicBrokerSelector.java
+++ 
b/pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/DynamicBrokerSelector.java
@@ -34,12 +34,15 @@ import org.I0Itec.zkclient.IZkDataListener;
 import org.I0Itec.zkclient.ZkClient;
 import org.I0Itec.zkclient.serialize.BytesPushThroughSerializer;
 import org.apache.pinot.client.utils.BrokerSelectorUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 
 /**
  * Maintains a mapping between table name and list of brokers
  */
 public class DynamicBrokerSelector implements BrokerSelector, IZkDataListener {
+  private static final Logger LOGGER = 
LoggerFactory.getLogger(DynamicBrokerSelector.class);
   private static final Random RANDOM = new Random();
 
   private final AtomicReference<Map<String, List<String>>> 
_tableToBrokerListMapRef = new AtomicReference<>();
@@ -84,6 +87,7 @@ public class DynamicBrokerSelector implements BrokerSelector, 
IZkDataListener {
       brokerSet.addAll(brokerList);
     }
     _allBrokerListRef.set(new ArrayList<>(brokerSet));
+    LOGGER.info("Refreshed table to broker list map: {}", 
_tableToBrokerListMapRef.get());
   }
 
   @Nullable


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