This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 5f59f915fef31ac34b351509a40e25df53181aaf
Author: Gabriel <gabrielleeb...@gmail.com>
AuthorDate: Fri Aug 30 14:20:11 2024 +0800
[fix](join) Fix partitioned hash join strategy (#40163)
## Proposed changes
Issue Number: close #xxx
<!--Describe your changes.-->
---
be/src/pipeline/pipeline_fragment_context.cpp | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/be/src/pipeline/pipeline_fragment_context.cpp
b/be/src/pipeline/pipeline_fragment_context.cpp
index 3d29536850b..a7c61c3a184 100644
--- a/be/src/pipeline/pipeline_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_fragment_context.cpp
@@ -1295,6 +1295,8 @@ Status
PipelineFragmentContext::_create_operator(ObjectPool* pool, const TPlanNo
_pipeline_parent_map.push(op->node_id(), cur_pipe);
_pipeline_parent_map.push(op->node_id(), build_side_pipe);
+ sink->set_followed_by_shuffled_join(sink->is_shuffled_hash_join());
+ op->set_followed_by_shuffled_join(op->is_shuffled_hash_join());
} else {
op.reset(new HashJoinProbeOperatorX(pool, tnode,
next_operator_id(), descs));
RETURN_IF_ERROR(cur_pipe->add_operator(op));
@@ -1315,6 +1317,8 @@ Status
PipelineFragmentContext::_create_operator(ObjectPool* pool, const TPlanNo
_pipeline_parent_map.push(op->node_id(), cur_pipe);
_pipeline_parent_map.push(op->node_id(), build_side_pipe);
+ sink->set_followed_by_shuffled_join(sink->is_shuffled_hash_join());
+ op->set_followed_by_shuffled_join(op->is_shuffled_hash_join());
}
_require_bucket_distribution =
_require_bucket_distribution ||
op->require_data_distribution();
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
