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

[pipelineX](dependency) split different dependencies (#27366)

Browse Source
This commit is contained in:
Gabriel
2023-11-22 12:50:39 +08:00
committed by GitHub
parent 604842526b
commit 5442e8d1fc
76 changed files with 1307 additions and 1275 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
be/src/runtime/buffer_control_block.cpp
View File

@ -305,10 +305,10 @@ void PipBufferControlBlock::set_dependency(
void PipBufferControlBlock::_update_dependency() {
if (_result_sink_dependency &&
(_batch_queue_empty || _buffer_rows < _buffer_limit || _is_cancelled)) {
_result_sink_dependency->set_ready_for_write();
_result_sink_dependency->set_ready();
} else if (_result_sink_dependency &&
(!_batch_queue_empty && _buffer_rows < _buffer_limit && !_is_cancelled)) {
_result_sink_dependency->block_writing();
_result_sink_dependency->block();
}
}