This is an automated email from the ASF dual-hosted git repository.
gabriellee 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 05596da1873 [fix](followup) Fix wrong partition num (#39916)
05596da1873 is described below
commit 05596da18731b16e4923a23aa09fc47301afffe8
Author: Gabriel <[email protected]>
AuthorDate: Tue Aug 27 08:47:49 2024 +0800
[fix](followup) Fix wrong partition num (#39916)
Follow-up for #39568
---
.../pipeline/local_exchange/local_exchange_sink_operator.cpp | 10 ++++------
1 file changed, 4 insertions(+), 6 deletions(-)
diff --git a/be/src/pipeline/local_exchange/local_exchange_sink_operator.cpp
b/be/src/pipeline/local_exchange/local_exchange_sink_operator.cpp
index 91a2c630418..f0a51696075 100644
--- a/be/src/pipeline/local_exchange/local_exchange_sink_operator.cpp
+++ b/be/src/pipeline/local_exchange/local_exchange_sink_operator.cpp
@@ -57,12 +57,10 @@ Status LocalExchangeSinkOperatorX::init(ExchangeType type,
const int num_buckets
_shuffle_idx_to_instance_idx[i] = {i, i};
}
}
- _partitioner.reset(
- _type == ExchangeType::HASH_SHUFFLE
- ? new
vectorized::Crc32HashPartitioner<vectorized::ShuffleChannelIds>(
- _num_partitions)
- : new
vectorized::Crc32HashPartitioner<vectorized::ShuffleChannelIds>(
- num_buckets));
+ _partitioner.reset(new
vectorized::Crc32HashPartitioner<vectorized::ShuffleChannelIds>(
+ _type == ExchangeType::HASH_SHUFFLE ||
_bucket_seq_to_instance_idx.empty()
+ ? _num_partitions
+ : num_buckets));
RETURN_IF_ERROR(_partitioner->init(_texprs));
}
return Status::OK();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
