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

Fix data version in multi prefetch

Browse Source
This commit is contained in:
haitaoyang
2023-05-16 11:41:39 +00:00
committed by ob-robot
parent 3f0ea494ab
commit f919dafe87
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/storage/access/ob_index_tree_prefetcher.cpp
View File

@ -432,7 +432,7 @@ int ObIndexTreeMultiPrefetcher::init(
access_ctx_ = &access_ctx; access_ctx_ = &access_ctx;
iter_param_ = &iter_param; iter_param_ = &iter_param;
index_read_info_ = iter_param.get_full_read_info()->get_index_read_info(); index_read_info_ = iter_param.get_full_read_info()->get_index_read_info();
data_version_ = sstable_->is_major_sstable() ? sstable_->get_snapshot_version() : sstable_->get_key().get_end_scn().get_val_for_tx(); data_version_ = sstable_->get_data_version();
data_block_cache_ = &(ObStorageCacheSuite::get_instance().get_block_cache()); data_block_cache_ = &(ObStorageCacheSuite::get_instance().get_block_cache());
index_block_cache_ = &(ObStorageCacheSuite::get_instance().get_index_block_cache()); index_block_cache_ = &(ObStorageCacheSuite::get_instance().get_index_block_cache());
ext_read_handles_.set_allocator(access_ctx.stmt_allocator_); ext_read_handles_.set_allocator(access_ctx.stmt_allocator_);
@ -472,7 +472,7 @@ int ObIndexTreeMultiPrefetcher::switch_context(
} else { } else {
sstable_ = &sstable; sstable_ = &sstable;
access_ctx_ = &access_ctx; access_ctx_ = &access_ctx;
data_version_ = sstable_->is_major_sstable() ? sstable_->get_snapshot_version() : sstable_->get_key().get_end_scn().get_val_for_tx(); data_version_ = sstable_->get_data_version();
rowkeys_ = static_cast<const common::ObIArray<blocksstable::ObDatumRowkey> *> (query_range); rowkeys_ = static_cast<const common::ObIArray<blocksstable::ObDatumRowkey> *> (query_range);
index_read_info_ = &index_read_info; index_read_info_ = &index_read_info;
index_tree_height_ = sstable_->get_meta().get_index_tree_height(); index_tree_height_ = sstable_->get_meta().get_index_tree_height();