[doris] branch master updated: [fix](multi-table) fix multi table task cannot end (#25056)

[yi...@apache.org]

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 8953179c110 [fix](multi-table) fix multi table task cannot end (#25056)
8953179c110 is described below

commit 8953179c110dcc41ae563ca132ba55f68a0abd7f
Author: HHoflittlefish777 <77...@users.noreply.github.com>
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 5c6bdaad036..49958400e76 100644
--- a/be/src/runtime/routine_load/routine_load_task_executor.cpp
+++ b/be/src/runtime/routine_load/routine_load_task_executor.cpp
@@ -342,7 +342,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);
-        static_cast<void>(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: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org