diff options
author | jonmv <venstad@gmail.com> | 2023-07-07 11:25:14 +0200 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2023-07-07 11:25:14 +0200 |
commit | aaa9f4184630a00f542c846902337fd1843198d5 (patch) | |
tree | 71a7ea6840b50bf1276847c1e92f4d0bd3f19893 /container-search/src/main/java/com/yahoo/search/dispatch/searchcluster | |
parent | 85c6a1ef03591bc1d696ef0b1a73ade7e8731bc7 (diff) |
Avoid overflow for warmup end time computation
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/searchcluster')
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); } } |