(pinot) branch master updated: Fix GROUP BY-Only Processing with accurateGroupByWithoutOrderBy (#15966)

[jackie]

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 6b475b7d4b Fix GROUP BY-Only Processing with 
accurateGroupByWithoutOrderBy (#15966)
6b475b7d4b is described below

commit 6b475b7d4bd97302eb3ecf6d5e892c46c219e44c
Author: Anand Kr Shaw <anandkrshawherit...@gmail.com>
AuthorDate: Tue Jun 3 00:54:40 2025 +0530

    Fix GROUP BY-Only Processing with accurateGroupByWithoutOrderBy (#15966)
---
 .../pinot/core/data/table/DeterministicConcurrentIndexedTable.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/pinot-core/src/main/java/org/apache/pinot/core/data/table/DeterministicConcurrentIndexedTable.java
 
b/pinot-core/src/main/java/org/apache/pinot/core/data/table/DeterministicConcurrentIndexedTable.java
index ed78ca66d3..6028100f23 100644
--- 
a/pinot-core/src/main/java/org/apache/pinot/core/data/table/DeterministicConcurrentIndexedTable.java
+++ 
b/pinot-core/src/main/java/org/apache/pinot/core/data/table/DeterministicConcurrentIndexedTable.java
@@ -45,7 +45,7 @@ public class DeterministicConcurrentIndexedTable extends 
IndexedTable {
   protected void upsertWithoutOrderBy(Key key, Record record) {
     ConcurrentSkipListMap<Key, Record> map = (ConcurrentSkipListMap<Key, 
Record>) _lookupMap;
 
-    if (map.size() < _resultSize) {
+    if (map.size() < _resultSize || map.containsKey(key)) {
       addOrUpdateRecord(key, record);
     } else if (!map.isEmpty() && key.compareTo(map.lastKey()) < 0) {
       addOrUpdateRecord(key, record);


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