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) {