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

fix medium compaction cannot schedule

Browse Source
This commit is contained in:
Fengjingkun
2023-12-19 08:51:01 +00:00
committed by ob-robot
parent f5f3fd0173
commit 5b236615b1
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -65,13 +65,13 @@ int ObMediumCompactionScheduleFunc::choose_medium_snapshot(
ObGetMergeTablesParam param; ObGetMergeTablesParam param;
param.merge_type_ = MEDIUM_MERGE; param.merge_type_ = MEDIUM_MERGE;
int64_t max_reserved_snapshot = 0; int64_t max_reserved_snapshot = 0;
int64_t medium_snapshot = 0;
ObTablet &tablet = *tablet_handle_.get_obj(); ObTablet &tablet = *tablet_handle_.get_obj();
if (OB_FAIL(ObAdaptiveMergePolicy::get_meta_merge_tables(param, ls_, tablet, result))) { if (OB_FAIL(ObAdaptiveMergePolicy::get_meta_merge_tables(param, ls_, tablet, result))) {
if (OB_NO_NEED_MERGE != ret) { if (OB_NO_NEED_MERGE != ret) {
LOG_WARN("failed to get meta merge tables", K(ret), K(param)); LOG_WARN("failed to get meta merge tables", K(ret), K(param));
} }
} else if (FALSE_IT(medium_snapshot = result.version_range_.snapshot_version_)) { } else if (FALSE_IT(medium_info.medium_snapshot_ = result.version_range_.snapshot_version_)) {
} else if (OB_FAIL(get_max_reserved_snapshot(max_reserved_snapshot))) { } else if (OB_FAIL(get_max_reserved_snapshot(max_reserved_snapshot))) {
LOG_WARN("failed to get reserved snapshot", K(ret), KPC(this)); LOG_WARN("failed to get reserved snapshot", K(ret), KPC(this));
} else if (medium_info.medium_snapshot_ < max_reserved_snapshot } else if (medium_info.medium_snapshot_ < max_reserved_snapshot
@ -86,7 +86,7 @@ int ObMediumCompactionScheduleFunc::choose_medium_snapshot(
if (OB_FAIL(ret)) { if (OB_FAIL(ret)) {
} else if (medium_info.medium_snapshot_ <= max_sync_medium_scn) { } else if (medium_info.medium_snapshot_ <= max_sync_medium_scn) {
ret = OB_NO_NEED_MERGE; ret = OB_NO_NEED_MERGE;
} else if (OB_FAIL(check_frequency(max_reserved_snapshot, medium_snapshot))) { // check schedule interval } else if (OB_FAIL(check_frequency(max_reserved_snapshot, medium_info.medium_snapshot_))) { // check schedule interval
if (OB_NO_NEED_MERGE != ret) { if (OB_NO_NEED_MERGE != ret) {
LOG_WARN("failed to check medium scn valid", K(ret), KPC(this)); LOG_WARN("failed to check medium scn valid", K(ret), KPC(this));
} }
@ -94,7 +94,7 @@ int ObMediumCompactionScheduleFunc::choose_medium_snapshot(
medium_info.set_basic_info( medium_info.set_basic_info(
ObMediumCompactionInfo::MEDIUM_COMPACTION, ObMediumCompactionInfo::MEDIUM_COMPACTION,
merge_reason_, merge_reason_,
medium_snapshot); medium_info.medium_snapshot_);
LOG_TRACE("choose_medium_snapshot", K(ret), KPC(this), K(result), K(medium_info)); LOG_TRACE("choose_medium_snapshot", K(ret), KPC(this), K(result), K(medium_info));
} }
return ret; return ret;