This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new f2693152bb9 [fix](multi-table-load) fix be core when multi table load
pipe finish fail (#37383)
f2693152bb9 is described below
commit f2693152bb96ab24148a50f858621c692b2533e3
Author: hui lai <[email protected]>
AuthorDate: Sun Jul 7 18:24:16 2024 +0800
[fix](multi-table-load) fix be core when multi table load pipe finish fail
(#37383)
pick #36269
---
be/src/runtime/routine_load/routine_load_task_executor.cpp | 2 +-
1 file changed, 1 insertion(+), 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 137a2c37f68..9b475ed2133 100644
--- a/be/src/runtime/routine_load/routine_load_task_executor.cpp
+++ b/be/src/runtime/routine_load/routine_load_task_executor.cpp
@@ -402,7 +402,7 @@ void
RoutineLoadTaskExecutor::exec_task(std::shared_ptr<StreamLoadContext> ctx,
}
// need memory order
multi_table_pipe->handle_consume_finished();
- HANDLE_ERROR(kafka_pipe->finish(), "finish multi table task failed");
+ HANDLE_MULTI_TABLE_ERROR(kafka_pipe->finish(), "finish multi table
task failed");
} else {
// start to consume, this may block a while
HANDLE_ERROR(consumer_grp->start_all(ctx, kafka_pipe), "consuming
failed");
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
