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

Clear evaluate flag in multiple merge

Browse Source
This commit is contained in:
DengzhiLiu
2024-02-06 19:26:16 +00:00
committed by ob-robot
parent 0b0cdb0dc4
commit c8042a8a3d
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/storage/access/ob_multiple_merge.cpp
View File

@ -380,6 +380,9 @@ int ObMultipleMerge::get_next_row(ObDatumRow *&row)
int ObMultipleMerge::get_next_rows(int64_t &count, int64_t capacity) int ObMultipleMerge::get_next_rows(int64_t &count, int64_t capacity)
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
if (OB_NOT_NULL(access_param_->get_op())) {
access_param_->get_op()->clear_evaluated_flag();
}
count = 0; count = 0;
if (access_param_->iter_param_.enable_pd_aggregate()) { if (access_param_->iter_param_.enable_pd_aggregate()) {
ObDatumRow *row = nullptr; ObDatumRow *row = nullptr;
@ -408,6 +411,9 @@ int ObMultipleMerge::get_next_rows(int64_t &count, int64_t capacity)
} else { } else {
ret = get_next_normal_rows(count, capacity); ret = get_next_normal_rows(count, capacity);
} }
if (OB_NOT_NULL(access_param_->get_op())) {
access_param_->get_op()->clear_evaluated_flag();
}
return ret; return ret;
} }