Apache/druid
1
0
Fork 0
mirror of https://github.com/apache/druid.git synced 2025-02-27 22:09:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix NPE (#16897)

Browse Source
This commit is contained in:
Sree Charan Manamala 2024-08-15 15:42:22 +05:30 committed by GitHub
parent 8181ef627a
commit 964cf47bb5
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
processing/src/main/java/org/apache/druid/query/rowsandcols/ArrayListRowsAndColumns.java
View File

@ -144,6 +144,9 @@ public class ArrayListRowsAndColumns<RowType> implements AppendableRowsAndColumn
{ {
if (!rowSignature.contains(name)) { if (!rowSignature.contains(name)) {
final Column retVal = extraColumns.get(name); final Column retVal = extraColumns.get(name);
if (retVal == null) {
return null;
}
if (numRows() == rows.size()) { if (numRows() == rows.size()) {
return retVal; return retVal;
} }

13
sql/src/test/resources/calcite/tests/window/arrayConcatAgg.sqlTest Normal file
View File

@ -0,0 +1,13 @@
type: "operatorValidation"
sql: |
SELECT
cityName,
array_concat_agg(ARRAY[cityName], 10000) over (PARTITION BY cityName)
FROM wikipedia
WHERE countryName='Austria' and cityName is not null
GROUP BY cityName
expectedResults:
- ["Horsching","[\"Horsching\"]"]
- ["Vienna","[\"Vienna\"]"]