Merge branch 'main' into feat/metadata-mgr

risingwavelabs · Jan 2, 2024 · 856664a · 856664a
2 parents c17f7d8 + 0c94093
commit 856664a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/meta/src/barrier/schedule.rs b/src/meta/src/barrier/schedule.rs
@@ -431,6 +431,7 @@ impl ScheduledBarriers {
         self.inner
             .num_uncheckpointed_barrier
             .load(Ordering::Relaxed)
+            + 1
             >= self.inner.checkpoint_frequency.load(Ordering::Relaxed)
             || self.inner.force_checkpoint.load(Ordering::Relaxed)
     }