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

fix count pushdown with filter rand() core

Browse Source
This commit is contained in:
obdev
2022-12-09 13:08:10 +00:00
committed by ob-robot
parent 448bf7c37f
commit f03258f1c0
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -545,7 +545,8 @@ int ObMultipleMerge::get_next_aggregate_row(ObDatumRow *&row)
ObAggregatedStore *agg_row_store = reinterpret_cast<ObAggregatedStore *>(block_row_store_); ObAggregatedStore *agg_row_store = reinterpret_cast<ObAggregatedStore *>(block_row_store_);
agg_row_store->reuse_aggregated_row(); agg_row_store->reuse_aggregated_row();
if (OB_NOT_NULL(access_param_->op_)) { if (OB_NOT_NULL(access_param_->op_)) {
access_param_->op_->get_eval_ctx().reuse(1); int64_t batch_size = max(1, access_param_->op_->get_batch_size());
access_param_->op_->get_eval_ctx().reuse(batch_size);
} }
while (OB_SUCC(ret) && !agg_row_store->is_end()) { while (OB_SUCC(ret) && !agg_row_store->is_end()) {
bool can_batch = false; bool can_batch = false;