From 79592c7f790af3063ccbb43f4a968489d0c2a0b3 Mon Sep 17 00:00:00 2001 From: "github-actions[bot]" <41898282+github-actions[bot]@users.noreply.github.com> Date: Sat, 26 Jul 2025 23:32:47 +0800 Subject: [PATCH] branch-2.1: [fix](load) stream load should not overwrite existing error status in filtered rows check #53393 (#53696) Cherry-picked from #53393 Co-authored-by: Kaijie Chen --- be/src/runtime/stream_load/stream_load_executor.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/be/src/runtime/stream_load/stream_load_executor.cpp b/be/src/runtime/stream_load/stream_load_executor.cpp index a436302dce..f13f763a1b 100644 --- a/be/src/runtime/stream_load/stream_load_executor.cpp +++ b/be/src/runtime/stream_load/stream_load_executor.cpp @@ -86,7 +86,7 @@ Status StreamLoadExecutor::execute_plan_fragment(std::shared_ptrloaded_bytes = state->num_bytes_load_total(); int64_t num_selected_rows = ctx->number_total_rows - ctx->number_unselected_rows; ctx->error_url = to_load_error_http_path(state->get_error_log_file_path()); - if (!ctx->group_commit && num_selected_rows > 0 && + if (status->ok() && !ctx->group_commit && num_selected_rows > 0 && (double)ctx->number_filtered_rows / num_selected_rows > ctx->max_filter_ratio) { // NOTE: Do not modify the error message here, for historical reasons, // some users may rely on this error message.