This is an automated email from the ASF dual-hosted git repository.
jacktengg 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 28dbbe605a8 [fix](local exchange) fix bug oflocal exchange free blocks
(#34530)
28dbbe605a8 is described below
commit 28dbbe605a8142276a360a1e523f429aafe8c8b6
Author: TengJianPing <18241664+jackte...@users.noreply.github.com>
AuthorDate: Wed May 8 21:40:29 2024 +0800
[fix](local exchange) fix bug oflocal exchange free blocks (#34530)
---
be/src/pipeline/local_exchange/local_exchanger.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/be/src/pipeline/local_exchange/local_exchanger.cpp
b/be/src/pipeline/local_exchange/local_exchanger.cpp
index c241b6bc5f3..eccf2a32d31 100644
--- a/be/src/pipeline/local_exchange/local_exchanger.cpp
+++ b/be/src/pipeline/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
