This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new 74e54c7fe0f branch-3.1: [fix](load) stream load should not overwrite
existing error status in filtered rows check #53393 (#53698)
74e54c7fe0f is described below
commit 74e54c7fe0fc15fd37b3b49e0fccd69b6ab2260b
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Jul 23 14:07:05 2025 +0800
branch-3.1: [fix](load) stream load should not overwrite existing error
status in filtered rows check #53393 (#53698)
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]
