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<PUBLISH_TIMEOUT>()) {
             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<PUBLISH_TIMEOUT>()) {
             ctx->need_rollback = false;
         }
+        ctx->status = status;
         return status;
     }
     // commit success, set need_rollback to false