diff --git a/src/storage/ob_partition_loop_worker.cpp b/src/storage/ob_partition_loop_worker.cpp
index c0697ceac2b40f3d86e9e025d2d80b10099be7a8..154683c15d0894cae2b96fe637d74d0acb471986 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 {