From 409edcb631d476fce116b320b68807e263ff63b1 Mon Sep 17 00:00:00 2001 From: aoiasd Date: Mon, 4 Nov 2024 11:01:17 +0800 Subject: [PATCH] fix merge sort segment loss data Signed-off-by: aoiasd --- internal/datanode/compaction/merge_sort.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/internal/datanode/compaction/merge_sort.go b/internal/datanode/compaction/merge_sort.go index bcf8dd8bb71e4..a43cc0c1796b3 100644 --- a/internal/datanode/compaction/merge_sort.go +++ b/internal/datanode/compaction/merge_sort.go @@ -105,6 +105,12 @@ func mergeSortMultipleSegments(ctx context.Context, deletedRowCount++ continue } + + // Filtering expired entity + if isExpiredEntity(collectionTtl, currentTs, typeutil.Timestamp(v.Timestamp)) { + expiredRowCount++ + continue + } return v, nil } } @@ -125,12 +131,6 @@ func mergeSortMultipleSegments(ctx context.Context, smallest := heap.Pop(&pq).(*PQItem) v := smallest.Value - // Filtering expired entity - if isExpiredEntity(collectionTtl, currentTs, typeutil.Timestamp(v.Timestamp)) { - expiredRowCount++ - continue - } - err := mWriter.Write(v) if err != nil { log.Warn("compact wrong, failed to writer row", zap.Error(err))