From c0f6eccb7a5edcfa6c57c110bb3c52808ffcb0ce Mon Sep 17 00:00:00 2001 From: yah01 Date: Wed, 29 Nov 2023 11:48:27 +0800 Subject: [PATCH] fix: No LevelZero segment in target (#28803) the incorrect filter causes all LevelZero segment filtered, so the deleted entities may be still visible related: #27349 Signed-off-by: yah01 --- internal/querycoordv2/meta/target_manager.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/querycoordv2/meta/target_manager.go b/internal/querycoordv2/meta/target_manager.go index 5485df5e5c..42adaf9298 100644 --- a/internal/querycoordv2/meta/target_manager.go +++ b/internal/querycoordv2/meta/target_manager.go @@ -25,6 +25,7 @@ import ( "go.uber.org/zap" "github.com/milvus-io/milvus/internal/proto/datapb" + "github.com/milvus-io/milvus/pkg/common" "github.com/milvus-io/milvus/pkg/log" "github.com/milvus-io/milvus/pkg/util/merr" "github.com/milvus-io/milvus/pkg/util/retry" @@ -206,7 +207,7 @@ func (mgr *TargetManager) PullNextTargetV2(broker Broker, collectionID int64, ch partitionSet := typeutil.NewUniqueSet(chosenPartitionIDs...) for _, segmentInfo := range segmentInfos { - if partitionSet.Contain(segmentInfo.GetPartitionID()) && segmentInfo.GetPartitionID() != -1 { + if partitionSet.Contain(segmentInfo.GetPartitionID()) || segmentInfo.GetPartitionID() == common.InvalidPartitionID { segments[segmentInfo.GetID()] = segmentInfo } }