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

add obtest about minor merge

Browse Source
This commit is contained in:
Fengjingkun 2024-07-15 15:11:31 +00:00 committed by ob-robot
parent 4bfb5b7272
commit 11eb878dd8
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
deps/oblib/src/lib/utility/ob_tracepoint_def.h vendored
View File

@ -436,6 +436,7 @@ GLOBAL_ERRSIM_POINT_DEF(748, EN_COMPACTION_ITER_SET_BATCH_CNT, "");
// please add new trace point after 750
GLOBAL_ERRSIM_POINT_DEF(751, EN_SESSION_LEAK_COUNT_THRESHOLD, "used to control the threshold of report session leak ERROR");
GLOBAL_ERRSIM_POINT_DEF(760, EN_DISABLE_TABLET_MINOR_MERGE, "used to stop scheduling minor merge");
GLOBAL_ERRSIM_POINT_DEF(800, EN_END_PARTICIPANT, "");
// compaction 801 - 899

7
src/storage/compaction/ob_partition_merge_policy.cpp
View File

@ -491,6 +491,13 @@ int ObPartitionMergePolicy::get_minor_merge_tables(
tablet, min_snapshot_version, max_snapshot_version,
true /*check_table_cnt*/, true /*is_multi_version_merge*/))) {
LOG_WARN("fail to calculate boundary version", K(ret));
} else {
#ifdef ERRSIM
ret = OB_E(EventTable::EN_DISABLE_TABLET_MINOR_MERGE) OB_SUCCESS;
if (OB_FAIL(ret)) {
FLOG_INFO("Errsim: disable data tablet minor merge", K(ret), "tablet_id", tablet.get_tablet_meta().tablet_id_);
}
#endif
}
if (OB_FAIL(ret)) {