This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 79592c7f790 branch-2.1: [fix](load) stream load should not overwrite
existing error status in filtered rows check #53393 (#53696)
79592c7f790 is described below
commit 79592c7f790af3063ccbb43f4a968489d0c2a0b3
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sat Jul 26 23:32:47 2025 +0800
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 <[email protected]>
---
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 a436302dce2..f13f763a1b9 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_ptr<StreamLoadConte
ctx->loaded_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.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
