From e0b443c0124d0d01762f7d85cb3525680d93c3e1 Mon Sep 17 00:00:00 2001
From: laihui <1353307710@qq.com>
Date: Thu, 13 Jun 2024 19:27:28 +0800
Subject: [PATCH] fix be core when multi table load pipe finish fail

---
 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 292f45ec030de4..958ad37f8d2d09 100644
--- a/be/src/runtime/routine_load/routine_load_task_executor.cpp
+++ b/be/src/runtime/routine_load/routine_load_task_executor.cpp
@@ -408,7 +408,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");