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 <[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 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: [email protected]
For additional commands, e-mail: [email protected]
