This is an automated email from the ASF dual-hosted git repository. morningman pushed a commit to branch branch-1.2-lts in repository https://gitbox.apache.org/repos/asf/doris.git
commit 340a657161cd4bf55c1a33cfe162c593b4b1c006 Author: xueweizhang <[email protected]> AuthorDate: Wed Mar 1 20:28:41 2023 +0800 [fix](insert) fix txn error reason clearly (#16997) Signed-off-by: nextdreamblue <[email protected]> --- 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 72cc0cd271..ba7a841271 100644 --- a/be/src/runtime/stream_load/stream_load_executor.cpp +++ b/be/src/runtime/stream_load/stream_load_executor.cpp @@ -204,6 +204,7 @@ Status StreamLoadExecutor::pre_commit_txn(StreamLoadContext* ctx) { if (status.is<PUBLISH_TIMEOUT>()) { ctx->need_rollback = false; } + ctx->status = status; return status; } // precommit success, set need_rollback to false @@ -285,6 +286,7 @@ Status StreamLoadExecutor::commit_txn(StreamLoadContext* ctx) { if (status.is<PUBLISH_TIMEOUT>()) { ctx->need_rollback = false; } + ctx->status = status; return status; } // commit success, set need_rollback to false --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
