From a56ffb2862edce375618c8b3a308474fdb7af29e Mon Sep 17 00:00:00 2001 From: LINxiansheng Date: Fri, 23 Jul 2021 13:42:20 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=86=B7partition=E5=86=99ch?= =?UTF-8?q?eckpoint=E6=97=A5=E5=BF=97=E7=9A=84=E9=A2=91=E7=8E=87=E6=8E=A7?= =?UTF-8?q?=E5=88=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/storage/ob_partition_loop_worker.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/storage/ob_partition_loop_worker.cpp b/src/storage/ob_partition_loop_worker.cpp index c0697ceac2..154683c15d 100644 --- a/src/storage/ob_partition_loop_worker.cpp +++ b/src/storage/ob_partition_loop_worker.cpp @@ -343,9 +343,9 @@ int ObPartitionLoopWorker::gene_checkpoint_() } else if (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) { - if (last_checkpoint <= max_trans_version || - ((cur_checkpoint - last_checkpoint_value_) > COLD_PARTITION_CHECKPOINT_INTERVAL && - REACH_COUNT_PER_SEC(COLD_PARTITION_CHECKPOINT_PS_LIMIT))) { + if (last_checkpoint <= max_trans_version + || ((cur_checkpoint - last_checkpoint_value_) > COLD_PARTITION_CHECKPOINT_INTERVAL + && EXECUTE_COUNT_PER_SEC(COLD_PARTITION_CHECKPOINT_PS_LIMIT))) { if (OB_FAIL(write_checkpoint_(cur_checkpoint))) { STORAGE_LOG(WARN, "write checkpoint failed", K(ret), K_(pkey), K(cur_checkpoint)); } else { -- GitLab