enhance: add the seal segment when dispatch delete msgs (milvus-io#34565

) /kind improvement Signed-off-by: SimFG <bang.fu@zilliz.com>
weiliu1031 · Jul 10, 2024 · b58a561 · b58a561
1 parent ebc68d2
commit b58a561
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/internal/datanode/writebuffer/l0_write_buffer.go b/internal/datanode/writebuffer/l0_write_buffer.go
@@ -90,7 +90,7 @@ func (wb *l0WriteBuffer) dispatchDeleteMsgs(groups []*inData, deleteMsgs []*msgs
 		pks := pksInDeleteMsgs[didx]
 		pkTss := delMsg.GetTimestamps()
 		partitionSegments := wb.metaCache.GetSegmentsBy(metacache.WithPartitionID(delMsg.PartitionID),
-			metacache.WithSegmentState(commonpb.SegmentState_Growing, commonpb.SegmentState_Flushing, commonpb.SegmentState_Flushed))
+			metacache.WithSegmentState(commonpb.SegmentState_Growing, commonpb.SegmentState_Sealed, commonpb.SegmentState_Flushing, commonpb.SegmentState_Flushed))
 		partitionGroups := lo.Filter(groups, func(inData *inData, _ int) bool {
 			return delMsg.GetPartitionID() == common.AllPartitionsID || delMsg.GetPartitionID() == inData.partitionID
 		})

diff --git a/pkg/config/env_source.go b/pkg/config/env_source.go
@@ -20,6 +20,7 @@ import (
 	"strings"
 
 	"github.com/cockroachdb/errors"
+
 	"github.com/milvus-io/milvus/pkg/util/typeutil"
 )