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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
