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

Reset row_flag of not exist row in getter

Browse Source
This commit is contained in:
DengzhiLiu 2023-02-17 08:17:00 +00:00 committed by ob-robot
parent 38ec0851ad
commit 9cfd298d40
3 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/storage/access/ob_single_merge.cpp
View File

@ -253,6 +253,7 @@ int ObSingleMerge::inner_get_next_row(ObDatumRow &row)
access_ctx_->query_flag_.set_not_use_row_cache();
nop_pos_.reset();
full_row_.count_ = 0;
full_row_.row_flag_.reset();
full_row_.row_flag_.set_flag(ObDmlFlag::DF_NOT_EXIST);
full_row_.snapshot_version_ = 0L;
access_ctx_->use_fuse_row_cache_ = enable_fuse_row_cache;

2
src/storage/access/ob_sstable_multi_version_row_iterator.cpp
View File

@ -81,6 +81,7 @@ int ObSSTableMultiVersionRowGetter::inner_open(
} else if (OB_FAIL(not_exist_row_.init(*access_ctx.get_range_allocator(), iter_param.get_out_col_cnt()))) {
LOG_WARN("fail to init datum row", K(ret));
} else {
not_exist_row_.row_flag_.reset();
not_exist_row_.row_flag_.set_flag(ObDmlFlag::DF_NOT_EXIST);
}
}
@ -205,6 +206,7 @@ int ObSSTableMultiVersionRowMultiGetter::inner_open(
} else if (OB_FAIL(not_exist_row_.init(*access_ctx.get_range_allocator(), iter_param.get_out_col_cnt()))) {
LOG_WARN("fail to init datum row", K(ret));
} else {
not_exist_row_.row_flag_.reset();
not_exist_row_.row_flag_.set_flag(ObDmlFlag::DF_NOT_EXIST);
}
}

1
src/storage/blocksstable/ob_micro_block_row_getter.cpp
View File

@ -410,6 +410,7 @@ int ObMicroBlockRowGetter::get_not_exist_row(const ObDatumRowkey &rowkey, const
LOG_WARN("fail to reserve datum row", K(ret), KPC(read_info));
} else {
row_.count_ = rowkey.get_datum_cnt();
row_.row_flag_.reset();
row_.row_flag_.set_flag(ObDmlFlag::DF_NOT_EXIST);
//TODO maybe we do not need to copy the rowkey datum
for (int64_t i = 0; i < rowkey.get_datum_cnt(); i++) {