You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by jl...@apache.org on 2025/04/03 22:05:28 UTC
(pinot) branch fix-array-agg-group-by created (now 4254e0f9f1)
This is an automated email from the ASF dual-hosted git repository.
jlli pushed a change to branch fix-array-agg-group-by
in repository https://gitbox.apache.org/repos/asf/pinot.git
at 4254e0f9f1 Fix Null value for group by queries when no aggregate was called
This branch includes the following new commits:
new 4254e0f9f1 Fix Null value for group by queries when no aggregate was called
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org
(pinot) 01/01: Fix Null value for group by queries when no aggregate was called
Posted by jl...@apache.org.
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 <jl...@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-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org