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 <j...@linkedin.com> 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: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org