From b0af97d8aaef69b0311a27ebfd0ccecba771db01 Mon Sep 17 00:00:00 2001
From: EmmyMiao87 <522274284@qq.com>
Date: Mon, 1 Jul 2019 16:05:49 +0800
Subject: [PATCH] Change error msg of mini load when PUBLISH_TIMEOUT (#1415)

---
 be/src/http/action/mini_load.cpp | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/be/src/http/action/mini_load.cpp b/be/src/http/action/mini_load.cpp
index ce90fbde1f..15cd300839 100644
--- a/be/src/http/action/mini_load.cpp
+++ b/be/src/http/action/mini_load.cpp
@@ -809,6 +809,9 @@ void MiniLoadAction::_new_handle(HttpRequest* req) {
     if (!ctx->status.ok()) {
         if (ctx->need_rollback) {
             _exec_env->stream_load_executor()->rollback_txn(ctx);
+            if (ctx->status.code() == TStatusCode::PUBLISH_TIMEOUT) {
+                ctx->status = Status::PublishTimeout("transation has been rollback because it was timeout in phase of publish");    
+            }
             ctx->need_rollback = false;
         }
         if (ctx->body_sink.get() != nullptr) {