diff --git a/internal/querynode/flow_graph_delete_node.go b/internal/querynode/flow_graph_delete_node.go index b3f930cc6646354912cd2bda60737e73b1baf03f..a51552e846e7caf34aa55b386d9d8a70cd3fe693 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 {