Fix wrong flushSegmentInfos in watchdmChannel request (#15740)

Signed-off-by: N xige-16 <xi.ge@zilliz.com>

Fix wrong flushSegmentInfos in watchdmChannel request (#15740)
Signed-off-by: N xige-16 <xi.ge@zilliz.com>
1e8e3eb9 · xige-16 · GitHub · 15291160 · 1e8e3eb9
隐藏空白更改
内联并排

Showing with 3 addition and 3 deletion

internal/querycoord/task.go internal/querycoord/task.go +3 -3

未找到文件。
--- a/internal/querycoord/task.go
+++ b/internal/querycoord/task.go
@@ -2019,10 +2019,10 @@ func mergeDmChannelInfo(infos []*datapb.VchannelInfo) map[string]*datapb.Vchanne
 		minPositionInfo := minPositions[info.ChannelName]
 		if info.SeekPosition.GetTimestamp() < minPositionInfo.SeekPosition.GetTimestamp() {
 			minPositionInfo.SeekPosition = info.SeekPosition
-			minPositionInfo.DroppedSegments = append(minPositionInfo.DroppedSegments, info.DroppedSegments...)
-			minPositionInfo.UnflushedSegments = append(minPositionInfo.UnflushedSegments, info.UnflushedSegments...)
-			minPositionInfo.FlushedSegments = append(minPositionInfo.FlushedSegments, info.FlushedSegments...)
 		}
+		minPositionInfo.DroppedSegments = append(minPositionInfo.DroppedSegments, info.DroppedSegments...)
+		minPositionInfo.UnflushedSegments = append(minPositionInfo.UnflushedSegments, info.UnflushedSegments...)
+		minPositionInfo.FlushedSegments = append(minPositionInfo.FlushedSegments, info.FlushedSegments...)
 	}

 	return minPositions