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

fix skip scan core

Browse Source
This commit is contained in:
chaser-ch
2023-09-09 12:06:14 +00:00
committed by ob-robot
parent b62974dae7
commit b3bb895b16
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/storage/access/ob_multiple_skip_scan_merge.cpp
View File

@ -388,10 +388,8 @@ int ObMultipleSkipScanMerge::update_scan_rows_range(blocksstable::ObDatumRow &ro
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
range_allocator_.reuse(); range_allocator_.reuse();
if (should_check_interrupt()) { if (should_check_interrupt() && OB_FAIL(THIS_WORKER.check_status())) {
if (OB_FAIL(THIS_WORKER.check_status())) { STORAGE_LOG(WARN, "query interrupt", K(ret));
STORAGE_LOG(WARN, "query interrupt, ", K(ret));
}
} else if (should_retire_to_scan()) { } else if (should_retire_to_scan()) {
// too many distinct prefix, retire to normal scan // too many distinct prefix, retire to normal scan
for (int64_t i = 0; OB_SUCC(ret) && i < ss_rowkey_prefix_cnt_; ++i) { for (int64_t i = 0; OB_SUCC(ret) && i < ss_rowkey_prefix_cnt_; ++i) {
@ -515,4 +513,4 @@ int ObMultipleSkipScanMerge::check_range_exceeded(bool &exceeded)
} }
} }
} }