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

[Bug](execute) fix get next non stop for eos on streaming preagg (#15611)

Browse Source 
* fix get nnext non stop for eos on streaming preagg

* update
This commit is contained in:
Pxl
2023-01-05 09:36:11 +08:00
committed by GitHub
parent 5ff5b8fc98
commit 93f5e440eb
2 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
be/src/vec/exec/vaggregation_node.cpp
View File

@ -522,21 +522,19 @@ Status AggregationNode::get_next(RuntimeState* state, Block* block, bool* eos) {
SCOPED_TIMER(_runtime_profile->total_time_counter());
if (_is_streaming_preagg) {
bool child_eos = false;
RETURN_IF_CANCELLED(state);
do {
release_block_memory(_preagg_block);
release_block_memory(_preagg_block);
while (_preagg_block.rows() == 0 && !_child_eos) {
RETURN_IF_ERROR_AND_CHECK_SPAN(
_children[0]->get_next_after_projects(
state, &_preagg_block, &child_eos,
state, &_preagg_block, &_child_eos,
std::bind((Status(ExecNode::*)(RuntimeState*, vectorized::Block*,
bool*)) &
ExecNode::get_next,
_children[0], std::placeholders::_1, std::placeholders::_2,
std::placeholders::_3)),
_children[0]->get_next_span(), child_eos);
} while (_preagg_block.rows() == 0 && !child_eos);
_children[0]->get_next_span(), _child_eos);
};
{
SCOPED_CONSUME_MEM_TRACKER(mem_tracker_growh());
if (_preagg_block.rows() != 0) {