Fix the issue where error codes are being overwritten

2024-12-09 05:19:11 +00:00
parent e7957aaa7f
commit c44523ad6a
2 changed files with 4 additions and 4 deletions
--- a/src/observer/table/ob_table_op_wrapper.cpp
+++ b/src/observer/table/ob_table_op_wrapper.cpp
@ -602,7 +602,7 @@ int ObHTableDeleteExecutor::delete_rows(ObTableQueryResult &result)
  int ret = OB_SUCCESS;
  const ObITableEntity *entity = nullptr;
  executor_->set_skip_scan(true);
-  while (OB_SUCC(result.get_next_entity(entity))) {
+  while (OB_SUCC(ret) && OB_SUCC(result.get_next_entity(entity))) {
    ObTableOperation op;
    op.set_type(ObTableOperationType::Type::DEL);
    op.set_entity(entity);