This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 5e8d460f0e7 branch-3.0: [fix](load) stream load should not overwrite
existing error status in filtered rows check #53393 (#53695)
5e8d460f0e7 is described below
commit 5e8d460f0e779743349743b26de10e51441079d9
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Jul 23 09:49:42 2025 +0800
branch-3.0: [fix](load) stream load should not overwrite existing error
status in filtered rows check #53393 (#53695)
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 1c1fa992f50..65b428e4b4f 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]
