fix multi table load core when pipe finish fail

apache · Jun 13, 2024 · 48a1000 · 48a1000
1 parent b3e0b89
commit 48a1000
Showing 1 changed file with 1 addition and 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
@@ -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");