milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix: duplicate consuming from stream for invisible segment (#40318) 

issue: #40207
pr: #40316

Signed-off-by: chyezh <chyezh@outlook.com>
pull/40338/head
Zhen Ye 2025-03-04 16:10:05 +08:00 committed by GitHub
parent 29c2354593
commit b55327046f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/datacoord/handler.go
View File

@ -86,10 +86,6 @@ func (h *ServerHandler) GetDataVChanPositions(channel RWChannel, partitionID Uni
// Skip bulk insert segments. // Skip bulk insert segments.
continue continue
} }
if s.GetIsInvisible() {
// skip invisible segments
continue
}
if s.GetState() == commonpb.SegmentState_Dropped { if s.GetState() == commonpb.SegmentState_Dropped {
droppedIDs.Insert(s.GetID()) droppedIDs.Insert(s.GetID())