This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit e2ea54c0a759c5ee1205d2f66ae76a0e5797d84a Author: Pxl <[email protected]> AuthorDate: Thu May 9 20:53:58 2024 +0800 [Improvement](sink) remove unused check on string's write_column_to_mysql (#34491) remove unused check on string's write_column_to_mysql --- be/src/vec/columns/column_string.h | 2 +- be/src/vec/data_types/serde/data_type_string_serde.h | 18 +----------------- 2 files changed, 2 insertions(+), 18 deletions(-) diff --git a/be/src/vec/columns/column_string.h b/be/src/vec/columns/column_string.h index 8aa531e466d..81a6a469b5b 100644 --- a/be/src/vec/columns/column_string.h +++ b/be/src/vec/columns/column_string.h @@ -133,7 +133,7 @@ public: } StringRef get_data_at(size_t n) const override { - assert(n < size()); + DCHECK_LT(n, size()); return StringRef(&chars[offset_at(n)], size_at(n)); } diff --git a/be/src/vec/data_types/serde/data_type_string_serde.h b/be/src/vec/data_types/serde/data_type_string_serde.h index f5d3e47ba16..b870b61d64f 100644 --- a/be/src/vec/data_types/serde/data_type_string_serde.h +++ b/be/src/vec/data_types/serde/data_type_string_serde.h @@ -255,23 +255,7 @@ private: int row_idx, bool col_const) const { const auto col_index = index_check_const(row_idx, col_const); const auto string_val = assert_cast<const ColumnType&>(column).get_data_at(col_index); - if (string_val.data == nullptr) { - if (string_val.size == 0) { - // 0x01 is a magic num, not useful actually, just for present "" - char* tmp_val = reinterpret_cast<char*>(0x01); - if (UNLIKELY(0 != result.push_string(tmp_val, string_val.size))) { - return Status::InternalError("pack mysql buffer failed."); - } - } else { - if (UNLIKELY(0 != result.push_null())) { - return Status::InternalError("pack mysql buffer failed."); - } - } - } else { - if (UNLIKELY(0 != result.push_string(string_val.data, string_val.size))) { - return Status::InternalError("pack mysql buffer failed."); - } - } + result.push_string(string_val.data, string_val.size); return Status::OK(); } }; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
