summaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster
diff options
context:
space:
mode:
authorjonmv <venstad@gmail.com>2023-07-07 11:25:14 +0200
committerjonmv <venstad@gmail.com>2023-07-07 11:25:14 +0200
commitaaa9f4184630a00f542c846902337fd1843198d5 (patch)
tree71a7ea6840b50bf1276847c1e92f4d0bd3f19893 /container-search/src/main/java/com/yahoo/search/dispatch/searchcluster
parent85c6a1ef03591bc1d696ef0b1a73ade7e8731bc7 (diff)
Avoid overflow for warmup end time computation
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/searchcluster')
-rw-r--r--container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java2
-rw-r--r--container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchGroupsImpl.java5
2 files changed, 4 insertions, 3 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java b/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java
index 1be45b01367..9c65cb3d4c0 100644
--- a/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java
+++ b/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchCluster.java
@@ -99,7 +99,7 @@ public class SearchCluster implements NodeManager<Node> {
private Collection<Group> groups() { return groups.groups(); }
public int groupsWithSufficientCoverage() {
- return (int)groups().stream().filter(Group::hasSufficientCoverage).count();
+ return (int) groups().stream().filter(Group::hasSufficientCoverage).count();
}
/**
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchGroupsImpl.java b/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchGroupsImpl.java
index 3e6e092ea70..514f0de4fec 100644
--- a/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchGroupsImpl.java
+++ b/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/SearchGroupsImpl.java
@@ -3,6 +3,7 @@ package com.yahoo.search.dispatch.searchcluster;
import com.google.common.math.Quantiles;
import java.util.Collection;
+import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;
@@ -38,7 +39,7 @@ public class SearchGroupsImpl implements SearchGroups {
public long medianDocumentsPerGroup() {
if (isEmpty()) return 0;
- var activeDocuments = groups().stream().map(Group::activeDocuments).toList();
- return (long) Quantiles.median().compute(activeDocuments);
+ double[] activeDocuments = groups().stream().mapToDouble(Group::activeDocuments).toArray();
+ return (long) Quantiles.median().computeInPlace(activeDocuments);
}
}