diff --git a/internal/querynode/impl.go b/internal/querynode/impl.go index 1d549543f3..76dfd1a5e4 100644 --- a/internal/querynode/impl.go +++ b/internal/querynode/impl.go @@ -328,6 +328,7 @@ func (node *QueryNode) LoadSegments(ctx context.Context, in *queryPb.LoadSegment return waitFunc() } +// ReleaseCollection clears all data related to this collecion on the querynode func (node *QueryNode) ReleaseCollection(ctx context.Context, in *queryPb.ReleaseCollectionRequest) (*commonpb.Status, error) { code := node.stateCode.Load().(internalpb.StateCode) if code != internalpb.StateCode_Healthy {