This is an automated email from the ASF dual-hosted git repository. kxiao pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit d120bbe99a5ca85cfaa211fab7615724f24d957e Author: HHoflittlefish777 <[email protected]> AuthorDate: Sat Oct 7 19:45:42 2023 +0800 [fix](multi-table) fix multi table task cannot end (#25056) When exec multi table task, it can not end when exec plan error, which causes other routine load task can not submit. --- be/src/runtime/routine_load/routine_load_task_executor.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/be/src/runtime/routine_load/routine_load_task_executor.cpp b/be/src/runtime/routine_load/routine_load_task_executor.cpp index 72285930b4f..023ebbe55f7 100644 --- a/be/src/runtime/routine_load/routine_load_task_executor.cpp +++ b/be/src/runtime/routine_load/routine_load_task_executor.cpp @@ -339,7 +339,8 @@ void RoutineLoadTaskExecutor::exec_task(std::shared_ptr<StreamLoadContext> ctx, if (ctx->is_multi_table) { // plan the rest of unplanned data auto multi_table_pipe = std::static_pointer_cast<io::MultiTablePipe>(ctx->body_sink); - multi_table_pipe->request_and_exec_plans(); + HANDLE_ERROR(multi_table_pipe->request_and_exec_plans(), + "multi tables task executes plan error"); // need memory order multi_table_pipe->set_consume_finished(); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
