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

Fix max rows returned in cg scanner

Browse Source
This commit is contained in:
DengzhiLiu
2024-02-10 01:06:04 +00:00
committed by ob-robot
parent ec5b02e4fc
commit d610ad1710
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/storage/column_store/ob_co_sstable_row_scanner.cpp
View File

@ -788,7 +788,7 @@ int ObCOSSTableRowScanner::fetch_output_rows()
int ret = OB_SUCCESS;
while (OB_SUCC(ret) && !batched_row_store_->is_end()) {
uint64_t count = 0;
uint64_t batch_size = iter_param_->op_->get_batch_size();
uint64_t batch_size = iter_param_->op_->eval_ctx_.get_batch_size();
if (nullptr != access_ctx_->limit_param_) {
batch_size = MIN(batch_size,
access_ctx_->limit_param_->offset_ + access_ctx_->limit_param_->limit_ - access_ctx_->out_cnt_);