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

fix sample block

Browse Source
This commit is contained in:
XIAO-HOU 2023-11-08 02:39:19 +00:00 committed by ob-robot
parent ec404798ef
commit 2fec019b4b
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -393,6 +393,7 @@ int ObBlockSampleRangeIterator::init_and_push_endkey_iterator(ObGetTableParam &g
ret = OB_INVALID_ARGUMENT;
STORAGE_LOG(WARN, "Invalid argument", K(get_table_param));
} else {
get_table_param.tablet_iter_.table_iter()->resume();
while (OB_SUCC(ret)) {
void *buf = nullptr;
ObITable *table = nullptr;
@ -660,7 +661,7 @@ int ObBlockSampleIterator::open(ObMultipleScanMerge &scan_merge,
STORAGE_LOG(WARN, "Invalid argument", K(ret), K(access_ctx), K(get_table_param));
} else if (OB_FAIL(range_iterator_.open(get_table_param, range, *access_ctx.stmt_allocator_, sample_info_->percent_, is_reverse_scan))) {
STORAGE_LOG(WARN, "Fail to init micro block iterator", K(ret));
}else {
} else {
scan_merge_ = &scan_merge;
has_opened_range_ = false;
access_ctx_ = &access_ctx;