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 dc706ed49b5 [fix](delete_predicate) fix wrong data after upgrade from v2.0 version (#40401) dc706ed49b5 is described below commit dc706ed49b5d1b45d45ea58e78d39de011c18bc5 Author: camby <camby...@tencent.com> AuthorDate: Mon Sep 9 10:20:55 2024 +0900 [fix](delete_predicate) fix wrong data after upgrade from v2.0 version (#40401) issue: https://github.com/apache/doris/issues/40390 related pr: https://github.com/apache/doris/pull/22442 --- be/src/olap/delete_handler.cpp | 15 ++++++++++++++- 1 file changed, 14 insertions(+), 1 deletion(-) diff --git a/be/src/olap/delete_handler.cpp b/be/src/olap/delete_handler.cpp index 10c6f50b300..2f4e77d036b 100644 --- a/be/src/olap/delete_handler.cpp +++ b/be/src/olap/delete_handler.cpp @@ -411,7 +411,20 @@ Status DeleteHandler::init(TabletSchemaSPtr tablet_schema, for (const auto& in_predicate : delete_condition.in_predicates()) { TCondition condition; condition.__set_column_name(in_predicate.column_name()); - auto col_unique_id = in_predicate.column_unique_id(); + + int32_t col_unique_id = -1; + if (in_predicate.has_column_unique_id()) { + col_unique_id = in_predicate.column_unique_id(); + } else { + // if upgrade from version 2.0.x, column_unique_id maybe not set + const auto& pre_column = + *DORIS_TRY(delete_pred_related_schema->column(condition.column_name)); + col_unique_id = pre_column.unique_id(); + } + if (col_unique_id == -1) { + return Status::Error<ErrorCode::DELETE_INVALID_CONDITION>( + "cannot get column_unique_id for column {}", condition.column_name); + } condition.__set_column_unique_id(col_unique_id); if (in_predicate.is_not_in()) { --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org