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

FIX: cg_sstable_cnt defense

Browse Source
This commit is contained in:
gaishun
2024-10-14 17:13:53 +00:00
committed by ob-robot
parent fbd8087138
commit 20c8524579
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/storage/tablet/ob_tablet_persister.cpp
View File

@ -1353,7 +1353,7 @@ int ObTabletPersister::fetch_and_persist_large_co_sstable(
sstable_persist_ctx.sstable_meta_write_ctxs_, sstable_persist_ctx.sstable_meta_write_ctxs_,
sstable_persist_ctx.block_info_set_))) { sstable_persist_ctx.block_info_set_))) {
LOG_WARN("failed to batch write sstable", K(ret)); LOG_WARN("failed to batch write sstable", K(ret));
} else if (OB_UNLIKELY(cg_addrs.count() != sstable_persist_ctx.cg_sstable_cnt_)) { } else if (OB_UNLIKELY(cg_addrs.count() != cg_sstables.count())) {
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;
LOG_WARN("get unexpected cg addrs count", K(ret), K(cg_addrs.count()), K(cg_sstables.count())); LOG_WARN("get unexpected cg addrs count", K(ret), K(cg_addrs.count()), K(cg_sstables.count()));
} else if (OB_FAIL(co_sstable->deep_copy(allocator, cg_addrs, tmp_co_sstable))) { } else if (OB_FAIL(co_sstable->deep_copy(allocator, cg_addrs, tmp_co_sstable))) {