Change error msg of mini load when PUBLISH_TIMEOUT (#1415)

2019-07-01 16:05:49 +08:00
parent 8db97998ba
commit b0af97d8aa
1 changed files with 3 additions and 0 deletions
--- 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) {