diff --git a/internal/datanode/flow_graph_delete_node.go b/internal/datanode/flow_graph_delete_node.go index 89451b7092..93105b1fb2 100644 --- a/internal/datanode/flow_graph_delete_node.go +++ b/internal/datanode/flow_graph_delete_node.go @@ -75,7 +75,7 @@ func (dn *deleteNode) Operate(in []Msg) []Msg { } if len(in) != 1 { - log.Error("Invalid operate message input in deleteNode", zap.Int("input length", len(in))) + log.Warn("Invalid operate message input in deleteNode", zap.Int("input length", len(in))) return []Msg{} } diff --git a/internal/indexcoord/index_coord.go b/internal/indexcoord/index_coord.go index 4d60771006..fd430c3910 100644 --- a/internal/indexcoord/index_coord.go +++ b/internal/indexcoord/index_coord.go @@ -991,7 +991,7 @@ func (i *IndexCoord) GetMetrics(ctx context.Context, req *milvuspb.GetMetricsReq if err == nil && ret != nil { return ret, nil } - log.Error("failed to get system info metrics from cache, recompute instead", + log.Warn("failed to get system info metrics from cache, recompute instead", zap.Error(err)) metrics, err := getSystemInfoMetrics(ctx, req, i) diff --git a/internal/querynode/shard_cluster.go b/internal/querynode/shard_cluster.go index 3d7ba83ad1..de5fa502ee 100644 --- a/internal/querynode/shard_cluster.go +++ b/internal/querynode/shard_cluster.go @@ -987,7 +987,7 @@ func (sc *ShardCluster) Search(ctx context.Context, req *querypb.SearchRequest, wg.Wait() if err != nil { - log.Error("failed to do search", + log.Warn("failed to do search", zap.Int64("sourceID", req.GetReq().GetBase().GetSourceID()), zap.Strings("channels", req.GetDmlChannels()), zap.Int64s("segmentIDs", req.GetSegmentIDs()),