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 fe881f8676e [fix](core) Fix `BUCKET_HASH_SHUFFLE` local exchanger
(#40149)
fe881f8676e is described below
commit fe881f8676e58e770b4714642d00d68da9561516
Author: Gabriel <[email protected]>
AuthorDate: Thu Aug 29 23:23:42 2024 +0800
[fix](core) Fix `BUCKET_HASH_SHUFFLE` local exchanger (#40149)
## Proposed changes
pick #40148
<!--Describe your changes.-->
---
be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 f4c2e1fbc7c..f999f74c3fd 100644
--- a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
@@ -834,7 +834,7 @@ Status PipelineXFragmentContext::_add_local_exchange_impl(
sink_id, local_exchange_id,
should_disable_bucket_shuffle ? _total_instances : _num_instances,
data_distribution.partition_exprs, bucket_seq_to_instance_idx));
- if (should_disable_bucket_shuffle &&
+ if (bucket_seq_to_instance_idx.empty() &&
data_distribution.distribution_type ==
ExchangeType::BUCKET_HASH_SHUFFLE) {
data_distribution.distribution_type = ExchangeType::HASH_SHUFFLE;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
