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 06612b9be31 [fix](local exchange) fix bug of local exchange free
blocks (#34531)
06612b9be31 is described below
commit 06612b9be31fdb37f769efcbb7a39e58e3b1fc85
Author: TengJianPing <18241664+jackte...@users.noreply.github.com>
AuthorDate: Wed May 8 16:26:51 2024 +0800
[fix](local exchange) fix bug of local exchange free blocks (#34531)
---
be/src/pipeline/pipeline_x/local_exchange/local_exchanger.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/be/src/pipeline/pipeline_x/local_exchange/local_exchanger.cpp
b/be/src/pipeline/pipeline_x/local_exchange/local_exchanger.cpp
index 0837a1212b9..71e427f8b25 100644
--- a/be/src/pipeline/pipeline_x/local_exchange/local_exchanger.cpp
+++ b/be/src/pipeline/pipeline_x/local_exchange/local_exchanger.cpp
@@ -104,7 +104,7 @@ Status ShuffleExchanger::_split_rows(RuntimeState* state,
const uint32_t* __rest
vectorized::Block data_block;
std::shared_ptr<ShuffleBlockWrapper> new_block_wrapper;
- if (_free_blocks.try_enqueue(data_block)) {
+ if (_free_blocks.try_dequeue(data_block)) {
new_block_wrapper =
ShuffleBlockWrapper::create_shared(std::move(data_block));
} else {
new_block_wrapper =
ShuffleBlockWrapper::create_shared(block->clone_empty());
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
