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 2c835ec918c [Fix] fix the divide zero in local shuffle (#37856)
2c835ec918c is described below
commit 2c835ec918cdf148c1b8fe77c9bd9020843e8cfa
Author: HappenLee <[email protected]>
AuthorDate: Tue Jul 16 00:41:18 2024 +0800
[Fix] fix the divide zero in local shuffle (#37856)
## Proposed changes
fix the divide zero in local shuffle
<!--Describe your changes.-->
---
be/src/pipeline/pipeline_fragment_context.cpp | 1 +
1 file changed, 1 insertion(+)
diff --git a/be/src/pipeline/pipeline_fragment_context.cpp
b/be/src/pipeline/pipeline_fragment_context.cpp
index 94837ff55a0..bca21c72c7e 100644
--- a/be/src/pipeline/pipeline_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_fragment_context.cpp
@@ -678,6 +678,7 @@ Status PipelineFragmentContext::_add_local_exchange_impl(
const std::map<int, int>& bucket_seq_to_instance_idx,
const std::map<int, int>& shuffle_idx_to_instance_idx,
const bool ignore_data_hash_distribution) {
+ num_buckets = num_buckets != 0 ? num_buckets : _num_instances;
auto& operator_xs = cur_pipe->operator_xs();
const auto downstream_pipeline_id = cur_pipe->id();
auto local_exchange_id = next_operator_id();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
