This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new b5ea3454a6 [Bug](aggregation)fix for map_agg when columns[1] is
nullable (#22932)
b5ea3454a6 is described below
commit b5ea3454a6317fbbabe4187552e431491b393173
Author: xy <[email protected]>
AuthorDate: Tue Aug 15 11:26:03 2023 +0800
[Bug](aggregation)fix for map_agg when columns[1] is nullable (#22932)
In the map_agg handler function, added the judgment on
columns[1]->is_nullable()
---
be/src/vec/aggregate_functions/aggregate_function_map.h | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/be/src/vec/aggregate_functions/aggregate_function_map.h
b/be/src/vec/aggregate_functions/aggregate_function_map.h
index 5901c6eb66..0c2a6b076e 100644
--- a/be/src/vec/aggregate_functions/aggregate_function_map.h
+++ b/be/src/vec/aggregate_functions/aggregate_function_map.h
@@ -280,7 +280,7 @@ public:
if (columns[0]->is_nullable()) {
auto& nullable_col = assert_cast<const
ColumnNullable&>(*columns[0]);
auto& null_map = nullable_col.get_null_map_data();
- if (columns[0]->is_nullable()) {
+ if (columns[1]->is_nullable()) {
this->streaming_agg_serialize_to_column_impl<true, true>(
num_rows, nullable_col.get_nested_column(),
*columns[1], null_map, writer);
} else {
@@ -288,7 +288,7 @@ public:
num_rows, nullable_col.get_nested_column(),
*columns[1], null_map, writer);
}
} else {
- if (columns[0]->is_nullable()) {
+ if (columns[1]->is_nullable()) {
this->streaming_agg_serialize_to_column_impl<false,
true>(num_rows, *columns[0],
*columns[1], {}, writer);
} else {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
