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

refactor prohibit_map & add medium_checker

Browse Source
This commit is contained in:
yangqise7en
2023-08-16 04:44:01 +00:00
committed by ob-robot
parent c07a4c7201
commit 5ad847706f
18 changed files with 636 additions and 300 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/storage/compaction/ob_medium_compaction_func.cpp
View File

@ -771,21 +771,6 @@ int ObMediumCompactionScheduleFunc::prepare_medium_info(
if (OB_TABLE_IS_DELETED != ret) {
LOG_WARN("failed to get table schema", KR(ret), KPC(this), K(medium_info));
}
} else if (OB_UNLIKELY(result.handle_.empty())) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("result is invalid empty", KR(ret), KPC(this), K(result));
} else {
ObSSTable *base_table = static_cast<ObSSTable *>(result.handle_.get_table(0));
ObSSTableMetaHandle sstable_meta_hdl;
int64_t schema_col_cnt = 0;
if (OB_FAIL(base_table->get_meta(sstable_meta_hdl))) {
LOG_WARN("failed to get base table meta", KR(ret));
} else if (OB_FAIL(medium_info.storage_schema_.get_stored_column_count_in_sstable(schema_col_cnt))) {
LOG_WARN("failed to get store column count", KR(ret), K(medium_info));
} else if (OB_UNLIKELY(sstable_meta_hdl.get_sstable_meta().get_column_count() > schema_col_cnt)) {
ret = OB_ERR_UNEXPECTED;
LOG_ERROR("medium column cnt is less than last major sstable", KR(ret), K(schema_col_cnt), K(sstable_meta_hdl));
}
}
}
if (FAILEDx(init_parallel_range_and_schema_changed(result, medium_info))) {