diff --git a/core/storage/sqlite3_ondisk.rs b/core/storage/sqlite3_ondisk.rs index eeb0417be..d033f49c2 100644 --- a/core/storage/sqlite3_ondisk.rs +++ b/core/storage/sqlite3_ondisk.rs @@ -1758,7 +1758,24 @@ pub fn read_entire_wal_dumb(file: &Arc) -> Result max_frame { + cached.pop(); + } + tracing::debug!("remove page {page} from the in-memory WAL index because it was past the last commited frame"); + } + pages_in_frames.truncate(max_frame as usize); + + wfs_data.nbackfills.store(0, Ordering::SeqCst); wfs_data.loaded.store(true, Ordering::SeqCst); });