database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](function) fix result column is nullable type when fast execute (#19889)

Browse Source
This commit is contained in:
YueW
2023-05-24 10:27:50 +08:00
committed by GitHub
parent 384a0c7aa7
commit 08ec5e2eb5
2 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
be/src/vec/exprs/vectorized_fn_call.cpp
View File

@ -154,7 +154,15 @@ bool VectorizedFnCall::fast_execute(FunctionContext* context, Block& block,
auto result_column =
block.get_by_name(result_column_name).column->convert_to_full_column_if_const();
block.replace_by_position(result, std::move(result_column));
auto& result_info = block.get_by_position(result);
if (result_info.type->is_nullable()) {
block.replace_by_position(result,
ColumnNullable::create(std::move(result_column),
ColumnUInt8::create(input_rows_count, 0)));
} else {
block.replace_by_position(result, std::move(result_column));
}
return true;
}

3
be/src/vec/functions/function_helpers.cpp
View File

@ -79,7 +79,8 @@ std::tuple<Block, ColumnNumbers> create_block_with_nested_columns(const Block& b
res.insert({ColumnConst::create(nested_col, col.column->size()), nested_type,
col.name});
} else {
LOG(FATAL) << "Illegal column for DataTypeNullable";
LOG(FATAL) << "Illegal column= " << col.column->get_name()
<< " for DataTypeNullable";
}
} else {
res.insert(col);