You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by da...@apache.org on 2024/09/04 01:24:01 UTC
(doris) branch branch-3.0 updated: [fix](core) Fix `BUCKET_HASH_SHUFFLE` local exchanger (#40148)
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
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new d40619e7cf6 [fix](core) Fix `BUCKET_HASH_SHUFFLE` local exchanger (#40148)
d40619e7cf6 is described below
commit d40619e7cf6b8f1a961df54695ead39f6716cde7
Author: Gabriel <ga...@gmail.com>
AuthorDate: Fri Aug 30 00:09:53 2024 +0800
[fix](core) Fix `BUCKET_HASH_SHUFFLE` local exchanger (#40148)
## Proposed changes
Issue Number: close #xxx
<!--Describe your changes.-->
---
be/src/pipeline/pipeline_fragment_context.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/be/src/pipeline/pipeline_fragment_context.cpp b/be/src/pipeline/pipeline_fragment_context.cpp
index 2a89f9be7b6..4ca3e20ed24 100644
--- a/be/src/pipeline/pipeline_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_fragment_context.cpp
@@ -730,7 +730,7 @@ Status PipelineFragmentContext::_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: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org