hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Fix distinct aggregate expr with rollup eval core

Browse Source
This commit is contained in:
hezuojiao
2023-01-10 03:15:47 +00:00
committed by ob-robot
parent c7f7f1cff5
commit 0739dcbef4
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/sql/engine/aggregate/ob_merge_groupby_op.cpp
View File

@ -737,6 +737,7 @@ int ObMergeGroupByOp::inner_get_next_row()
} }
} }
} }
clear_evaluated_flag();
LOG_TRACE("after inner_get_next_row", "aggr_hold_size", LOG_TRACE("after inner_get_next_row", "aggr_hold_size",
aggr_processor_.get_aggr_hold_size(), "aggr_used_size", aggr_processor_.get_aggr_hold_size(), "aggr_used_size",
aggr_processor_.get_aggr_used_size()); aggr_processor_.get_aggr_used_size());
@ -975,6 +976,7 @@ int ObMergeGroupByOp::inner_get_next_batch(const int64_t max_row_cnt)
} }
} }
clear_evaluated_flag();
LOG_DEBUG("after inner_get_next_batch", "aggr_hold_size", LOG_DEBUG("after inner_get_next_batch", "aggr_hold_size",
aggr_processor_.get_aggr_hold_size(), "aggr_used_size", aggr_processor_.get_aggr_hold_size(), "aggr_used_size",
aggr_processor_.get_aggr_used_size(), K(output_batch_cnt), K(ret)); aggr_processor_.get_aggr_used_size(), K(output_batch_cnt), K(ret));