From b55327046f7a7a3098aefaa64a12b4a3c1e107c2 Mon Sep 17 00:00:00 2001 From: Zhen Ye Date: Tue, 4 Mar 2025 16:10:05 +0800 Subject: [PATCH] fix: duplicate consuming from stream for invisible segment (#40318) issue: #40207 pr: #40316 Signed-off-by: chyezh --- internal/datacoord/handler.go | 4 ---- 1 file changed, 4 deletions(-) diff --git a/internal/datacoord/handler.go b/internal/datacoord/handler.go index 99361bdfa9..ae109a6ac4 100644 --- a/internal/datacoord/handler.go +++ b/internal/datacoord/handler.go @@ -86,10 +86,6 @@ func (h *ServerHandler) GetDataVChanPositions(channel RWChannel, partitionID Uni // Skip bulk insert segments. continue } - if s.GetIsInvisible() { - // skip invisible segments - continue - } if s.GetState() == commonpb.SegmentState_Dropped { droppedIDs.Insert(s.GetID())