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

修复冷partition写checkpoint日志的频率控制

Browse Source
This commit is contained in:
LINxiansheng
2021-07-23 13:42:20 +08:00
committed by wangzelin.wzl
parent 0df13a572f
commit a56ffb2862
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/storage/ob_partition_loop_worker.cpp
View File

@ -343,9 +343,9 @@ int ObPartitionLoopWorker::gene_checkpoint_()
} else if (last_max_trans_version < max_trans_version) { } else if (last_max_trans_version < max_trans_version) {
ATOMIC_STORE(&last_max_trans_version_, max_trans_version); ATOMIC_STORE(&last_max_trans_version_, max_trans_version);
} else if (last_max_trans_version == max_trans_version) { } else if (last_max_trans_version == max_trans_version) {
if (last_checkpoint <= max_trans_version || if (last_checkpoint <= max_trans_version
((cur_checkpoint - last_checkpoint_value_) > COLD_PARTITION_CHECKPOINT_INTERVAL && || ((cur_checkpoint - last_checkpoint_value_) > COLD_PARTITION_CHECKPOINT_INTERVAL
REACH_COUNT_PER_SEC(COLD_PARTITION_CHECKPOINT_PS_LIMIT))) { && EXECUTE_COUNT_PER_SEC(COLD_PARTITION_CHECKPOINT_PS_LIMIT))) {
if (OB_FAIL(write_checkpoint_(cur_checkpoint))) { if (OB_FAIL(write_checkpoint_(cur_checkpoint))) {
STORAGE_LOG(WARN, "write checkpoint failed", K(ret), K_(pkey), K(cur_checkpoint)); STORAGE_LOG(WARN, "write checkpoint failed", K(ret), K_(pkey), K(cur_checkpoint));
} else { } else {