fix: Aviod add negative missing count (milvus-io#38748)

See also: milvus-io#34665 Signed-off-by: yangxuan <[email protected]>
bigsheeper · Dec 26, 2024 · 4df444e · 4df444e
1 parent 94955e5
commit 4df444e
Showing 1 changed file with 5 additions and 1 deletion.
diff --git 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 {