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 7ce97259179 branch-3.1: [fix](load) fix missing error url return for
stream load #54115 (#54267)
7ce97259179 is described below
commit 7ce97259179e5703b268c4d30e48c22eef8ee45a
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Aug 4 15:56:24 2025 +0800
branch-3.1: [fix](load) fix missing error url return for stream load #54115
(#54267)
Cherry-picked from #54115
Co-authored-by: Xin Liao <[email protected]>
---
be/src/pipeline/pipeline_fragment_context.cpp | 4 ++++
.../load_p0/stream_load/test_stream_load_with_filtered_rows.groovy | 2 +-
2 files changed, 5 insertions(+), 1 deletion(-)
diff --git a/be/src/pipeline/pipeline_fragment_context.cpp
b/be/src/pipeline/pipeline_fragment_context.cpp
index a8e62f4f6d3..6736ff89827 100644
--- a/be/src/pipeline/pipeline_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_fragment_context.cpp
@@ -207,6 +207,10 @@ void PipelineFragmentContext::cancel(const Status reason) {
auto stream_load_ctx = _exec_env->new_load_stream_mgr()->get(_query_id);
if (stream_load_ctx != nullptr) {
stream_load_ctx->pipe->cancel(reason.to_string());
+ // Set error URL here because after pipe is cancelled, stream load
execution may return early.
+ // We need to set the error URL at this point to ensure error
information is properly
+ // propagated to the client.
+ stream_load_ctx->error_url = get_load_error_url();
}
for (auto& tasks : _tasks) {
diff --git
a/regression-test/suites/load_p0/stream_load/test_stream_load_with_filtered_rows.groovy
b/regression-test/suites/load_p0/stream_load/test_stream_load_with_filtered_rows.groovy
index 1801d2be52d..1a338a0cbf2 100644
---
a/regression-test/suites/load_p0/stream_load/test_stream_load_with_filtered_rows.groovy
+++
b/regression-test/suites/load_p0/stream_load/test_stream_load_with_filtered_rows.groovy
@@ -21,7 +21,7 @@ import org.apache.http.util.EntityUtils
import java.text.SimpleDateFormat
-suite("test_stream_load_with_filtered_rows", "p2") {
+suite("test_stream_load_with_filtered_rows", "p0") {
sql "show tables"
// test length of input is too long than schema.
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
