fix release sealed segment on unwatch channel (#25555)

Signed-off-by: Wei Liu <wei.liu@zilliz.com>
pull/25260/head
wei liu 2023-07-13 14:30:29 +08:00 committed by GitHub
parent 012fd1152a
commit b72809db15
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions

View File

@ -375,7 +375,7 @@ func (node *QueryNode) UnsubDmChannel(ctx context.Context, req *querypb.UnsubDmC
delegator.Close()
node.pipelineManager.Remove(req.GetChannelName())
node.manager.Segment.RemoveBy(segments.WithChannel(req.GetChannelName()))
node.manager.Segment.RemoveBy(segments.WithChannel(req.GetChannelName()), segments.WithType(segments.SegmentTypeGrowing))
node.tSafeManager.Remove(req.GetChannelName())
}