diff --git a/src/common/meta/src/region_registry.rs b/src/common/meta/src/region_registry.rs index 49d97f8a2f..4beb24c008 100644 --- a/src/common/meta/src/region_registry.rs +++ b/src/common/meta/src/region_registry.rs @@ -113,8 +113,10 @@ impl LeaderRegionManifestInfo { pub fn prunable_entry_id(&self) -> u64 { match self { LeaderRegionManifestInfo::Mito { - flushed_entry_id, .. - } => *flushed_entry_id, + flushed_entry_id, + topic_latest_entry_id, + .. + } => (*flushed_entry_id).max(*topic_latest_entry_id), LeaderRegionManifestInfo::Metric { data_flushed_entry_id, data_topic_latest_entry_id,