From 919956999b964322bf7a6e14ba745dc7ccdfed1f Mon Sep 17 00:00:00 2001 From: Yuhan Wang Date: Wed, 23 Apr 2025 07:48:32 +0800 Subject: [PATCH] fix: use max in flushed entry id and topic latest entry id (#5946) --- src/common/meta/src/region_registry.rs | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) 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,