fix merge sort segment loss data

Signed-off-by: aoiasd <[email protected]>
aoiasd · Nov 4, 2024 · 409edcb · 409edcb
1 parent 51cb2fb
commit 409edcb
Showing 1 changed file with 6 additions and 6 deletions.
diff --git 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))