Load data retry for schema errors

2024-10-16 22:45:24 +00:00
parent 4021098694
commit 9c5b058572
1 changed files with 2 additions and 1 deletions
--- a/src/sql/engine/cmd/ob_load_data_impl.cpp
+++ b/src/sql/engine/cmd/ob_load_data_impl.cpp
@ -1683,7 +1683,8 @@ int ObLoadDataSPImpl::handle_returned_insert_task(ObExecContext &ctx,
      }
    } else if (is_server_down_error(err)
               || is_master_changed_error(err)
-               || is_partition_change_error(err)) {
+               || is_partition_change_error(err)
+               || is_schema_error(err)) {
      task_status = can_retry ? TASK_NEED_RETRY : TASK_FAILED;
      if (OB_FAIL(part_mgr->update_part_location(ctx))) {
        LOG_WARN("fail to update location cache", K(ret));