(pinot) 01/01: Fix Null value for group by queries when no aggregate was called

[jlli]

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

jlli pushed a commit to branch fix-array-agg-group-by
in repository https://gitbox.apache.org/repos/asf/pinot.git

commit 4254e0f9f15f9863ac8f605a172514686c859bee
Author: jlli_LinkedIn <j...@linkedin.com>
AuthorDate: Thu Apr 3 15:05:07 2025 -0700

    Fix Null value for group by queries when no aggregate was called
---
 .../pinot/core/operator/blocks/results/GroupByResultsBlock.java      | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/pinot-core/src/main/java/org/apache/pinot/core/operator/blocks/results/GroupByResultsBlock.java
 
b/pinot-core/src/main/java/org/apache/pinot/core/operator/blocks/results/GroupByResultsBlock.java
index da09681d5d..425bb2052c 100644
--- 
a/pinot-core/src/main/java/org/apache/pinot/core/operator/blocks/results/GroupByResultsBlock.java
+++ 
b/pinot-core/src/main/java/org/apache/pinot/core/operator/blocks/results/GroupByResultsBlock.java
@@ -252,8 +252,9 @@ public class GroupByResultsBlock extends BaseResultsBlock {
         Object[] values = iterator.next().getValues();
         for (int i = 0; i < numColumns; i++) {
           Object value = values[i];
-          assert value != null;
-          if (storedColumnDataTypes[i] == ColumnDataType.OBJECT) {
+          if (value == null) {
+            dataTableBuilder.setNull(i);
+          } else if (storedColumnDataTypes[i] == ColumnDataType.OBJECT) {
             dataTableBuilder.setColumn(i, aggregationFunctions[i - 
numKeyColumns].serializeIntermediateResult(value));
           } else {
             setDataTableColumn(storedColumnDataTypes[i], dataTableBuilder, i, 
value);


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