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

fix 3-stage aggr can not dump last group

Browse Source
This commit is contained in:
18523270951@163.com
2023-08-25 02:47:54 +00:00
committed by ob-robot
parent 0ca997cb54
commit d3f3058ecf
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/sql/engine/aggregate/ob_hash_groupby_op.cpp
View File

@ -1976,11 +1976,11 @@ int ObHashGroupByOp::batch_process_duplicate_data(
agged_row_cnt_++; agged_row_cnt_++;
LOG_DEBUG("exist item", K(gri_cnt_per_batch_), K(*exist_curr_gr_item), LOG_DEBUG("exist item", K(gri_cnt_per_batch_), K(*exist_curr_gr_item),
K(i), K(agged_row_cnt_)); K(i), K(agged_row_cnt_));
} else if (!enable_dump_ } else if (NULL == bloom_filter
|| local_group_rows_.size() < MIN_INMEM_GROUPS && (!enable_dump_
|| process_check_dump || local_group_rows_.size() < MIN_INMEM_GROUPS
|| (NULL == bloom_filter || process_check_dump
&& !need_start_dump(input_rows, est_part_cnt, force_check_dump))) { || !need_start_dump(input_rows, est_part_cnt, force_check_dump))) {
++agged_row_cnt_; ++agged_row_cnt_;
++agged_group_cnt_; ++agged_group_cnt_;
ObGroupRowItem *tmp_gr_item = NULL; ObGroupRowItem *tmp_gr_item = NULL;
@ -2267,11 +2267,11 @@ int ObHashGroupByOp::group_child_batch_rows(const ObChunkDatumStore::StoredRow *
const_cast<ObGroupRowItem *>(exist_curr_gr_item)->group_row_count_in_batch_++; const_cast<ObGroupRowItem *>(exist_curr_gr_item)->group_row_count_in_batch_++;
LOG_DEBUG("exist item", K(gri_cnt_per_batch_), K(*exist_curr_gr_item), LOG_DEBUG("exist item", K(gri_cnt_per_batch_), K(*exist_curr_gr_item),
K(i), K(agged_row_cnt_)); K(i), K(agged_row_cnt_));
} else if (!enable_dump_ } else if (NULL == bloom_filter
|| local_group_rows_.size() < MIN_INMEM_GROUPS && (!enable_dump_
|| process_check_dump || local_group_rows_.size() < MIN_INMEM_GROUPS
|| (NULL == bloom_filter || process_check_dump
&& !need_start_dump(input_rows, est_part_cnt, force_check_dump))) { || !need_start_dump(input_rows, est_part_cnt, force_check_dump))) {
// add new local group // add new local group
if (!batch_hash_calculated) { if (!batch_hash_calculated) {
calc_groupby_exprs_hash_batch(dup_groupby_exprs_, child_brs); calc_groupby_exprs_hash_batch(dup_groupby_exprs_, child_brs);