diff --git a/foyer-storage/src/large/recover.rs b/foyer-storage/src/large/recover.rs index 13b6d3de..51faa8e3 100644 --- a/foyer-storage/src/large/recover.rs +++ b/foyer-storage/src/large/recover.rs @@ -180,8 +180,10 @@ impl RecoverRunner { } region_manager.reclaim_semaphore().add_permits(permits); region_manager.reclaim_semaphore_countdown().reset(countdown); - // Update the manifest sequence watermark with the smallest possible value. - config.manifest.update_sequence_watermark(seq).await?; + if watermark > seq { + // Update the manifest sequence watermark with the smallest possible value. + config.manifest.update_sequence_watermark(seq).await?; + } // Note: About reclaim semaphore permits and countdown: //