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

[CP]Fix storage stat and mysqltest

Browse Source
This commit is contained in:
haitaoyang
2024-06-20 04:22:38 +00:00
committed by ob-robot
parent e1ddbd0f0a
commit 1e812be3c2
3 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -786,6 +786,7 @@ int ObMultipleMerge::process_fuse_row(const bool not_using_static_engine,
bool need_skip = false;
bool is_filter_filtered = false;
out_row = nullptr;
access_ctx_->table_store_stat_.logical_read_cnt_++;
if (OB_FAIL((not_using_static_engine)
? project_row(in_row,
access_param_->iter_param_.out_cols_project_,

2
src/storage/access/ob_multiple_merge.h
View File

@ -185,7 +185,7 @@ OB_INLINE int ObMultipleMerge::update_and_report_tablet_stat()
int ret = OB_SUCCESS;
EVENT_ADD(ObStatEventIds::STORAGE_READ_ROW_COUNT, scan_cnt_);
if (NULL != access_ctx_->table_scan_stat_) {
access_ctx_->table_scan_stat_->access_row_cnt_ += row_stat_.filt_del_count_;
access_ctx_->table_scan_stat_->access_row_cnt_ += access_ctx_->table_store_stat_.logical_read_cnt_;
access_ctx_->table_scan_stat_->rowkey_prefix_ = access_ctx_->table_store_stat_.rowkey_prefix_;
access_ctx_->table_scan_stat_->bf_filter_cnt_ += access_ctx_->table_store_stat_.bf_filter_cnt_;
access_ctx_->table_scan_stat_->bf_access_cnt_ += access_ctx_->table_store_stat_.bf_access_cnt_;

4
src/storage/blocksstable/ob_micro_block_row_scanner.cpp
View File

@ -306,7 +306,6 @@ int ObIMicroBlockRowScanner::inner_get_next_row(const ObDatumRow *&row)
}
}
if (OB_SUCC(ret) && OB_NOT_NULL(context_)) {
++context_->table_store_stat_.logical_read_cnt_;
++context_->table_store_stat_.physical_read_cnt_;
}
LOG_DEBUG("get next row", K(ret), KPC(row), K_(macro_id));
@ -1406,9 +1405,6 @@ int ObMultiVersionMicroBlockRowScanner::inner_get_next_row_impl(const ObDatumRow
LOG_ERROR("row is invalid", KPC(ret_row));
} else {
LOG_DEBUG("row is valid", KPC(ret_row));
if (OB_NOT_NULL(context_)) {
++context_->table_store_stat_.logical_read_cnt_;
}
}
} else if (OB_UNLIKELY(OB_SUCCESS == ret || OB_ITER_END == ret)) {
if (!reverse_scan_ && (last_ < reader_->row_count() - 1) &&