This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new baa5264c7b4 branch-4.0: [opt](profile) change the node name format of
MultiCastDataStreamer #59422 (#59433)
baa5264c7b4 is described below
commit baa5264c7b4609613a11478d45139190510cb832
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Dec 29 17:25:03 2025 +0800
branch-4.0: [opt](profile) change the node name format of
MultiCastDataStreamer #59422 (#59433)
Cherry-picked from #59422
Co-authored-by: Mingyu Chen (Rayner) <[email protected]>
---
be/src/pipeline/exec/multi_cast_data_stream_sink.cpp | 11 ++++++++++-
be/src/pipeline/pipeline_fragment_context.cpp | 5 +++--
2 files changed, 13 insertions(+), 3 deletions(-)
diff --git a/be/src/pipeline/exec/multi_cast_data_stream_sink.cpp
b/be/src/pipeline/exec/multi_cast_data_stream_sink.cpp
index ee3c3c8055e..362de4fb42b 100644
--- a/be/src/pipeline/exec/multi_cast_data_stream_sink.cpp
+++ b/be/src/pipeline/exec/multi_cast_data_stream_sink.cpp
@@ -26,7 +26,16 @@ namespace doris::pipeline {
std::string MultiCastDataStreamSinkLocalState::name_suffix() {
auto* parent = static_cast<MultiCastDataStreamSinkOperatorX*>(_parent);
- return fmt::format(operator_name_suffix, parent->operator_id());
+ auto& dest_ids = parent->dests_id();
+ std::string result = "(";
+ for (size_t i = 0; i < dest_ids.size(); ++i) {
+ if (i > 0) {
+ result += ", ";
+ }
+ result += fmt::format("dest_id={}", dest_ids[i]);
+ }
+ result += ")";
+ return fmt::format(result + operator_name_suffix, parent->operator_id());
}
std::shared_ptr<BasicSharedState>
MultiCastDataStreamSinkOperatorX::create_shared_state() const {
diff --git a/be/src/pipeline/pipeline_fragment_context.cpp
b/be/src/pipeline/pipeline_fragment_context.cpp
index 8ab48be87b1..6f909e95e5f 100644
--- a/be/src/pipeline/pipeline_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_fragment_context.cpp
@@ -1139,8 +1139,9 @@ Status
PipelineFragmentContext::_create_data_sink(ObjectPool* pool, const TDataS
OperatorPtr source_op;
// 1. create and set the source operator of
multi_cast_data_stream_source for new pipeline
source_op = std::make_shared<MultiCastDataStreamerSourceOperatorX>(
- multi_cast_node_id, i, pool,
thrift_sink.multi_cast_stream_sink.sinks[i],
- row_desc, /*operator_id=*/source_id);
+ /*node_id*/ source_id, /*consumer_id*/ i, pool,
+ thrift_sink.multi_cast_stream_sink.sinks[i], row_desc,
+ /*operator_id=*/source_id);
RETURN_IF_ERROR(new_pipeline->add_operator(
source_op, params.__isset.parallel_instances ?
params.parallel_instances : 0));
// 2. create and set sink operator of data stream sender for new
pipeline
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
