diff --git a/core/storage/wal.rs b/core/storage/wal.rs index e4f0a7121..15ffc17a5 100644 --- a/core/storage/wal.rs +++ b/core/storage/wal.rs @@ -1182,6 +1182,7 @@ impl Wal for WalFile { self.checkpoint_inner(pager, _write_counter, mode) .inspect_err(|_| { let _ = self.checkpoint_guard.take(); + self.ongoing_checkpoint.state = CheckpointState::Start; }) }