You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2023/07/01 15:59:53 UTC
[doris] 05/06: [fix] slot id not found with projection in multi cast sender (#21407)
This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch runtimefilter_multi_send
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 68af15bbb091b1514def789008f0d890fc047d59
Author: Jerry Hu <mr...@gmail.com>
AuthorDate: Sat Jul 1 22:54:26 2023 +0800
[fix] slot id not found with projection in multi cast sender (#21407)
---
be/src/pipeline/pipeline_fragment_context.cpp | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
diff --git a/be/src/pipeline/pipeline_fragment_context.cpp b/be/src/pipeline/pipeline_fragment_context.cpp
index a97128ee32..2b916c46a7 100644
--- a/be/src/pipeline/pipeline_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_fragment_context.cpp
@@ -767,9 +767,17 @@ Status PipelineFragmentContext::_create_sink(int sender_id, const TDataSink& thr
_multi_cast_stream_sink_senders.resize(sender_size);
for (int i = 0; i < sender_size; ++i) {
auto new_pipeline = add_pipeline();
+
+ auto row_desc =
+ !thrift_sink.multi_cast_stream_sink.sinks[i].output_exprs.empty()
+ ? RowDescriptor(
+ _runtime_state->desc_tbl(),
+ {thrift_sink.multi_cast_stream_sink.sinks[i].output_tuple_id},
+ {false})
+ : sink_->row_desc();
// 1. create the data stream sender sink
_multi_cast_stream_sink_senders[i].reset(new vectorized::VDataStreamSender(
- _runtime_state.get(), _runtime_state->obj_pool(), sender_id, sink_->row_desc(),
+ _runtime_state.get(), _runtime_state->obj_pool(), sender_id, row_desc,
thrift_sink.multi_cast_stream_sink.sinks[i],
thrift_sink.multi_cast_stream_sink.destinations[i], 16 * 1024, false));
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org