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 <mrh...@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-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
