From 34c5e84e9f1fb2edd6be993098b6cab442ec4cb2 Mon Sep 17 00:00:00 2001 From: xueweizhang Date: Wed, 1 Mar 2023 20:28:41 +0800 Subject: [PATCH] [fix](insert) fix txn error reason clearly (#16997) Signed-off-by: nextdreamblue --- be/src/runtime/stream_load/stream_load_executor.cpp | 2 ++ 1 file changed, 2 insertions(+) diff --git a/be/src/runtime/stream_load/stream_load_executor.cpp b/be/src/runtime/stream_load/stream_load_executor.cpp index e9d6c105f9..9fe991f153 100644 --- a/be/src/runtime/stream_load/stream_load_executor.cpp +++ b/be/src/runtime/stream_load/stream_load_executor.cpp @@ -198,6 +198,7 @@ Status StreamLoadExecutor::pre_commit_txn(StreamLoadContext* ctx) { if (status.is()) { ctx->need_rollback = false; } + ctx->status = status; return status; } // precommit success, set need_rollback to false @@ -279,6 +280,7 @@ Status StreamLoadExecutor::commit_txn(StreamLoadContext* ctx) { if (status.is()) { ctx->need_rollback = false; } + ctx->status = status; return status; } // commit success, set need_rollback to false