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

add refresh epoch in merge round

Browse Source
This commit is contained in:
a1iive 2025-01-06 16:46:16 +00:00 committed by ob-robot
parent b4ae55339c
commit dd1debf532
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/rootserver/freeze/ob_major_merge_scheduler.cpp
View File

@ -831,6 +831,7 @@ void ObMajorMergeScheduler::check_merge_interval_time(const bool is_merging, con
LOG_WARN("fail to get global merge start time", KR(ret), K_(tenant_id));
} else {
const int64_t MAX_NO_MERGE_INTERVAL = 36 * 3600 * 1000 * 1000L; // 36 hours
const int64_t MAX_REFRESH_EPOCH_IN_MERGE_INTERVAL = 6 * 3600 * 1000 * 1000L; // 6 hours
if ((global_last_merged_time < 0) || (global_merge_start_time < 0)) {
ret = OB_ERR_UNEXPECTED;
LOG_WARN("unexpected global_last_merged_time and global_merge_start_time", KR(ret),
@ -914,6 +915,12 @@ void ObMajorMergeScheduler::check_merge_interval_time(const bool is_merging, con
}
}
}
if (OB_SUCC(ret) && !is_paused() && (start_service_time > 0) &&
is_merging && (now - max_merge_time) > MAX_REFRESH_EPOCH_IN_MERGE_INTERVAL) {
if (OB_FAIL(try_update_epoch_and_reload())) {
LOG_WARN("fail to try_update_epoch_and_reload", KR(ret), "cur_epoch", get_epoch());
}
}
}
}