This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 37c5848e7dd [fix](join) Fix partitioned hash join strategy (#40163)
37c5848e7dd is described below
commit 37c5848e7dd7718167e1e62e4cab06561d370282
Author: Gabriel <[email protected]>
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 19d94997531..51cfd73e549 100644
--- a/be/src/pipeline/pipeline_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_fragment_context.cpp
@@ -1333,6 +1333,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));
@@ -1353,6 +1355,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: [email protected]
For additional commands, e-mail: [email protected]
