enhance: Make sure every segment only trigger flush task once by chan…

…nel.flushTs. (#33034) Signed-off-by: aoiasd <[email protected]>
milvus-io · May 17, 2024 · 62848d3 · 62848d3
1 parent bbf3a27
commit 62848d3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/datanode/segment_sync_policy.go b/internal/datanode/segment_sync_policy.go
@@ -91,7 +91,7 @@ func syncSegmentsAtTs() segmentSyncPolicy {
  flushTs := c.getFlushTs()
  if flushTs != 0 && ts >= flushTs {
  segmentsWithBuffer := lo.Filter(segments, func(segment *Segment, _ int) bool {
- return !segment.isBufferEmpty()
+ return !segment.isBufferEmpty() && segment.minBufferTs() <= flushTs
  })
  segmentIDs := lo.Map(segmentsWithBuffer, func(segment *Segment, _ int) UniqueID {
  return segment.segmentID