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

[BUG] remove error for 6213 in mvcc gc

Browse Source
This commit is contained in:
Handora
2023-02-09 14:31:37 +00:00
committed by ob-robot
parent 6192a06fb9
commit ead52c09f3
1 changed files with 13 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/storage/concurrency_control/ob_multi_version_garbage_collector.cpp
View File

@ -432,10 +432,22 @@ int ObMultiVersionGarbageCollector::study_min_unallocated_WRS(
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
const int64_t current_time = ObTimeUtility::current_time();
const int64_t max_read_stale_time =
transaction::ObWeakReadUtil::max_stale_time_for_weak_consistency(MTL_ID());
if (OB_FAIL(MTL(transaction::ObTransService*)->get_weak_read_snapshot_version( if (OB_FAIL(MTL(transaction::ObTransService*)->get_weak_read_snapshot_version(
transaction::ObWeakReadUtil::max_stale_time_for_weak_consistency(MTL_ID()), max_read_stale_time,
min_unallocated_WRS))) { min_unallocated_WRS))) {
MVCC_LOG(WARN, "fail to get weak read snapshot", K(ret)); MVCC_LOG(WARN, "fail to get weak read snapshot", K(ret));
if (OB_REPLICA_NOT_READABLE == ret) {
// The global weak read service cannot provide services in some cases(for
// example backup cluster's weak read service may hung during recovery).
// So instead of report the error, we decide to use the max allowed stale
// time for garbage collector.
min_unallocated_WRS.convert_from_ts(current_time - max_read_stale_time);
ret = OB_SUCCESS;
}
} }
return ret; return ret;