From 4df444ef25c5c353f2e98602fd3f90728cedfe92 Mon Sep 17 00:00:00 2001 From: XuanYang-cn Date: Thu, 26 Dec 2024 18:58:56 +0800 Subject: [PATCH] fix: Aviod add negative missing count (#38748) See also: #34665 Signed-off-by: yangxuan --- internal/datanode/compaction/compactor_common.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/internal/datanode/compaction/compactor_common.go b/internal/datanode/compaction/compactor_common.go index d21b681154..2ff9c15b4e 100644 --- a/internal/datanode/compaction/compactor_common.go +++ b/internal/datanode/compaction/compactor_common.go @@ -84,7 +84,11 @@ func (filter *EntityFilter) GetDeltalogDeleteCount() int { } func (filter *EntityFilter) GetMissingDeleteCount() int { - return filter.GetDeltalogDeleteCount() - filter.GetDeletedCount() + diff := filter.GetDeltalogDeleteCount() - filter.GetDeletedCount() + if diff <= 0 { + diff = 0 + } + return diff } func (filter *EntityFilter) isEntityDeleted(pk interface{}, pkTs typeutil.Timestamp) bool {