feat: update flushed manifest version after replaying

GreptimeTeam · Aug 22, 2023 · a5a8df3 · a5a8df3
1 parent bdc3f1d
commit a5a8df3
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/src/storage/src/manifest/region.rs b/src/storage/src/manifest/region.rs
@@ -44,8 +44,10 @@ pub struct RegionManifestCheckpointer {
 
 impl RegionManifestCheckpointer {
     pub(crate) fn set_flushed_manifest_version(&self, manifest_version: ManifestVersion) {
+        let current = self.flushed_manifest_version.load(Ordering::Relaxed);
+
         self.flushed_manifest_version
-            .store(manifest_version, Ordering::Relaxed);
+            .store(current.max(manifest_version), Ordering::Relaxed);
     }
 }
 

diff --git a/src/storage/src/region.rs b/src/storage/src/region.rs
@@ -356,6 +356,11 @@ impl<S: LogStore> RegionImpl<S> {
             .replay(recovered_metadata_after_flushed, writer_ctx)
             .await?;
 
+        // Update flushed manifest version after replaying
+        store_config
+            .manifest
+            .set_flushed_manifest_version(shared.version_control.current().manifest_version());
+
         let inner = Arc::new(RegionInner {
             shared,
             writer,