database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[pipelineX](bug) Fix 'No broadcast buffer left' (#27298)

Browse Source
This commit is contained in:
Gabriel
2023-11-20 22:37:21 +08:00
committed by GitHub
parent c0f22e8feb
commit 87a7de7660
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
be/src/pipeline/exec/exchange_sink_operator.h
View File

@ -82,13 +82,13 @@ public:
void set_available_block(int available_block) { _available_block = available_block; }
void return_available_block() {
_available_block++;
WriteDependency::set_ready_for_write();
if (_available_block.fetch_add(1) == 0) {
WriteDependency::set_ready_for_write();
}
}
void take_available_block() {
auto old_vale = _available_block.fetch_sub(1);
if (old_vale == 1) {
if (_available_block.fetch_sub(1) == 1) {
WriteDependency::block_writing();
}
}