This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 1e3f96e127f [fix](group commit) fix content length in stream load
(#56100)
1e3f96e127f is described below
commit 1e3f96e127f2eac14e465034870fffbfb0b1397e
Author: meiyi <[email protected]>
AuthorDate: Wed Sep 17 07:57:30 2025 +0800
[fix](group commit) fix content length in stream load (#56100)
---
be/src/http/action/http_stream.cpp | 6 +++++-
be/src/http/action/stream_load.cpp | 6 +++++-
be/src/pipeline/pipeline_fragment_context.cpp | 3 +++
3 files changed, 13 insertions(+), 2 deletions(-)
diff --git a/be/src/http/action/http_stream.cpp
b/be/src/http/action/http_stream.cpp
index 495ddf38bd9..86827415106 100644
--- a/be/src/http/action/http_stream.cpp
+++ b/be/src/http/action/http_stream.cpp
@@ -382,7 +382,11 @@ Status HttpStreamAction::process_put(HttpRequest* http_req,
content_length *= 3;
}
}
- ctx->put_result.pipeline_params.__set_content_length(content_length);
+ if (ctx->put_result.__isset.params) {
+ ctx->put_result.params.__set_content_length(content_length);
+ } else {
+
ctx->put_result.pipeline_params.__set_content_length(content_length);
+ }
}
TPipelineFragmentParamsList mocked;
return _exec_env->stream_load_executor()->execute_plan_fragment(ctx,
mocked);
diff --git a/be/src/http/action/stream_load.cpp
b/be/src/http/action/stream_load.cpp
index d8175b17f86..1f7b1986315 100644
--- a/be/src/http/action/stream_load.cpp
+++ b/be/src/http/action/stream_load.cpp
@@ -792,7 +792,11 @@ Status StreamLoadAction::_process_put(HttpRequest*
http_req,
content_length *= 3;
}
}
- ctx->put_result.params.__set_content_length(content_length);
+ if (ctx->put_result.__isset.params) {
+ ctx->put_result.params.__set_content_length(content_length);
+ } else {
+
ctx->put_result.pipeline_params.__set_content_length(content_length);
+ }
}
VLOG_NOTICE << "params is " <<
apache::thrift::ThriftDebugString(ctx->put_result.params);
diff --git a/be/src/pipeline/pipeline_fragment_context.cpp
b/be/src/pipeline/pipeline_fragment_context.cpp
index b7ba42224a3..1e246d2a003 100644
--- a/be/src/pipeline/pipeline_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_fragment_context.cpp
@@ -442,6 +442,9 @@ Status PipelineFragmentContext::_build_pipeline_tasks(const
doris::TPipelineFrag
if (request.__isset.wal_id) {
task_runtime_state->set_wal_id(request.wal_id);
}
+ if (request.__isset.content_length) {
+
task_runtime_state->set_content_length(request.content_length);
+ }
task_runtime_state->set_desc_tbl(_desc_tbl);
task_runtime_state->set_per_fragment_instance_idx(local_params.sender_id);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
