This is an automated email from the ASF dual-hosted git repository.
jlli pushed a commit to branch hotfix-array-agg
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/hotfix-array-agg by this push:
new e7f418442f Fix Null value for group by queries when no aggregate was
called (#15458)
e7f418442f is described below
commit e7f418442fb0069694549779334b9ba4f3b6e3f0
Author: Jialiang Li <[email protected]>
AuthorDate: Thu Apr 3 15:54:12 2025 -0700
Fix Null value for group by queries when no aggregate was called (#15458)
---
.../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 21eeea73ca..3413b79a1b 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
@@ -243,8 +243,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: [email protected]
For additional commands, e-mail: [email protected]
