diff --git a/internal/querynode/impl.go b/internal/querynode/impl.go index d73a0e6fe1..6e0a494814 100644 --- a/internal/querynode/impl.go +++ b/internal/querynode/impl.go @@ -376,6 +376,7 @@ func (node *QueryNode) ReleaseCollection(ctx context.Context, in *queryPb.Releas return status, nil } +// ReleasePartitions clears all data related to this partition on the querynode func (node *QueryNode) ReleasePartitions(ctx context.Context, in *queryPb.ReleasePartitionsRequest) (*commonpb.Status, error) { code := node.stateCode.Load().(internalpb.StateCode) if code != internalpb.StateCode_Healthy {