From a4cfd1cb46aa8b5b075f74eb684e63ca4dd4b1b5 Mon Sep 17 00:00:00 2001 From: xige-16 Date: Mon, 29 Nov 2021 21:17:46 +0800 Subject: [PATCH] [skip ci]Add comment for releasePartitions (#12410) Signed-off-by: xige-16 --- internal/querycoord/cluster.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/querycoord/cluster.go b/internal/querycoord/cluster.go index 4df4127d1d..87f3674ddb 100644 --- a/internal/querycoord/cluster.go +++ b/internal/querycoord/cluster.go @@ -441,21 +441,21 @@ func (c *queryNodeCluster) releasePartitions(ctx context.Context, nodeID int64, if targetNode != nil { err := targetNode.releasePartitions(ctx, in) if err != nil { - log.Debug("ReleasePartitions: queryNode release partitions error", zap.String("error", err.Error())) + log.Debug("releasePartitions: queryNode release partitions error", zap.String("error", err.Error())) return err } for _, partitionID := range in.PartitionIDs { err = c.clusterMeta.releasePartition(in.CollectionID, partitionID) if err != nil { - log.Debug("ReleasePartitions: meta release partitions error", zap.String("error", err.Error())) + log.Debug("releasePartitions: meta release partitions error", zap.String("error", err.Error())) return err } } return nil } - return fmt.Errorf("ReleasePartitions: can't find query node by nodeID, nodeID = %d", nodeID) + return fmt.Errorf("releasePartitions: can't find query node by nodeID, nodeID = %d", nodeID) } func (c *queryNodeCluster) getSegmentInfoByID(ctx context.Context, segmentID UniqueID) (*querypb.SegmentInfo, error) {