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

jackie 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 180bc231fd use ThreadLocalRandom in PinotQueryResource (#13855)
180bc231fd is described below

commit 180bc231fd63ee7d2f384b94870aeafbb989e487
Author: sullis <git...@seansullivan.com>
AuthorDate: Tue Aug 20 12:01:10 2024 -0700

    use ThreadLocalRandom in PinotQueryResource (#13855)
---
 .../apache/pinot/controller/api/resources/PinotQueryResource.java    | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotQueryResource.java
 
b/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotQueryResource.java
index 0ed96a907c..500f2458d5 100644
--- 
a/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotQueryResource.java
+++ 
b/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotQueryResource.java
@@ -35,8 +35,8 @@ import java.util.List;
 import java.util.Map;
 import java.util.Map.Entry;
 import java.util.Objects;
-import java.util.Random;
 import java.util.Set;
+import java.util.concurrent.ThreadLocalRandom;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 import javax.annotation.Nullable;
@@ -88,7 +88,6 @@ import org.slf4j.LoggerFactory;
 @Path("/")
 public class PinotQueryResource {
   private static final Logger LOGGER = 
LoggerFactory.getLogger(PinotQueryResource.class);
-  private static final Random RANDOM = new Random();
 
   @Inject
   SqlQueryExecutor _sqlQueryExecutor;
@@ -332,7 +331,7 @@ public class PinotQueryResource {
     }
 
     // Send query to a random broker.
-    return instanceIds.get(RANDOM.nextInt(instanceIds.size()));
+    return 
instanceIds.get(ThreadLocalRandom.current().nextInt(instanceIds.size()));
   }
 
   private List<String> findCommonBrokerInstances(Set<String> brokerTenants) {


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

Reply via email to