From 7a0d5ed6c4973b09460b7e744da3550f6ecb7d9f Mon Sep 17 00:00:00 2001 From: yukun Date: Mon, 22 Nov 2021 23:11:14 +0800 Subject: [PATCH] Fix delete after create index (#12174) Signed-off-by: fishpenguin --- internal/querynode/flow_graph_delete_node.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/querynode/flow_graph_delete_node.go b/internal/querynode/flow_graph_delete_node.go index b3f930cc66..a51552e846 100644 --- a/internal/querynode/flow_graph_delete_node.go +++ b/internal/querynode/flow_graph_delete_node.go @@ -102,7 +102,7 @@ func (dNode *deleteNode) delete(deleteData *deleteData, segmentID UniqueID, wg * return } - if targetSegment.segmentType != segmentTypeSealed { + if targetSegment.segmentType != segmentTypeSealed && targetSegment.segmentType != segmentTypeIndexing { return } @@ -116,7 +116,7 @@ func (dNode *deleteNode) delete(deleteData *deleteData, segmentID UniqueID, wg * return } - log.Debug("Do delete done", zap.Int("len", len(deleteData.deleteIDs[segmentID])), zap.Int64("segmentID", segmentID)) + log.Debug("Do delete done", zap.Int("len", len(deleteData.deleteIDs[segmentID])), zap.Int64("segmentID", segmentID), zap.Any("SegmentType", targetSegment.segmentType)) } func newDeleteNode(historicalReplica ReplicaInterface) *deleteNode {