Minor fix

Signed-off-by: Siddhant Deshmukh <[email protected]>
opensearch-project · Sep 4, 2024 · d891909 · d891909
1 parent 357d2cd
commit d891909
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...main/java/org/opensearch/plugin/insights/core/service/grouper/MinMaxHeapQueryGrouper.java b/...main/java/org/opensearch/plugin/insights/core/service/grouper/MinMaxHeapQueryGrouper.java
@@ -251,7 +251,7 @@ private void addToMaxPQPromoteToMinPQ(SearchQueryRecord aggregateSearchQueryReco
     }
 
     private boolean checkMaxGroupsLimitReached(String groupId) {
-        if (maxGroups <= maxHeapQueryStore.size()) {
+        if (maxGroups <= maxHeapQueryStore.size() && minHeapTopQueriesStore.size() >= topNSize) {
             log.warn(
                 "Exceeded [{}] setting threshold which is set at {}. Discarding new group with id {}.",
                 TOP_N_QUERIES_MAX_GROUPS_EXCLUDING_N.getKey(),