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
The following commit(s) were added to refs/heads/runtimefilter_multi_send by
this push:
new 67e42c4d7f [fix] slot id not found with projection in multi cast
sender (#21407)
67e42c4d7f is described below
commit 67e42c4d7fcde14200338722af68b8f6f663e63e
Author: Jerry Hu <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
