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) {