This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 531fe542079 [fix](join) Fix partitioned hash join strategy (#40164)
531fe542079 is described below
commit 531fe542079db436859984285eb4afc1ae9b3b37
Author: Gabriel <[email protected]>
AuthorDate: Fri Aug 30 12:44:42 2024 +0800
[fix](join) Fix partitioned hash join strategy (#40164)
## Proposed changes
pick #40163
<!--Describe your changes.-->
---
be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
index f999f74c3fd..d9a1d936800 100644
--- a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
@@ -1161,6 +1161,8 @@ Status
PipelineXFragmentContext::_create_operator(ObjectPool* pool, const TPlanN
_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));
@@ -1181,6 +1183,8 @@ Status
PipelineXFragmentContext::_create_operator(ObjectPool* pool, const TPlanN
_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: [email protected]
For additional commands, e-mail: [email protected]
