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 f8a594c25dd fix column is decimalv3 cast to decimalv2 make be core
(#26204)
f8a594c25dd is described below
commit f8a594c25dd4c0c8287401d5905bc19ebf427435
Author: amory <wangqian...@selectdb.com>
AuthorDate: Wed Nov 1 22:30:30 2023 +0800
fix column is decimalv3 cast to decimalv2 make be core (#26204)
---
be/src/vec/sink/vmysql_result_writer.cpp | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
diff --git a/be/src/vec/sink/vmysql_result_writer.cpp
b/be/src/vec/sink/vmysql_result_writer.cpp
index 4452014b486..714f406d20e 100644
--- a/be/src/vec/sink/vmysql_result_writer.cpp
+++ b/be/src/vec/sink/vmysql_result_writer.cpp
@@ -147,7 +147,15 @@ Status
VMysqlResultWriter<is_binary_format>::append_block(Block& input_block) {
// from expr
DataTypeSerDeSPtr serde;
if (_output_vexpr_ctxs[i]->root()->type().is_decimal_v2_type()) {
- serde =
std::make_shared<DataTypeDecimalSerDe<vectorized::Decimal128>>(scale, 27);
+ if (_output_vexpr_ctxs[i]->root()->is_nullable()) {
+ auto nested_serde =
+
std::make_shared<DataTypeDecimalSerDe<vectorized::Decimal128>>(scale,
+
27);
+ serde =
std::make_shared<DataTypeNullableSerDe>(nested_serde);
+ } else {
+ serde =
std::make_shared<DataTypeDecimalSerDe<vectorized::Decimal128>>(scale,
+
27);
+ }
} else {
serde = block.get_by_position(i).type->get_serde();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
