diff --git a/internal/datacoord/garbage_collector.go b/internal/datacoord/garbage_collector.go index 0144137202..49a5d762b4 100644 --- a/internal/datacoord/garbage_collector.go +++ b/internal/datacoord/garbage_collector.go @@ -215,7 +215,7 @@ func (gc *garbageCollector) checkDroppedSegmentGC(segment *SegmentInfo, // If the child is GC'ed first, then childSegment will be nil. if childSegment != nil && !indexSet.Contain(childSegment.GetID()) { log.WithRateGroup("GC_FAIL_COMPACT_TO_NOT_INDEXED", 1, 60). - RatedWarn(60, "skipping GC when compact target segment is not indexed", + RatedInfo(60, "skipping GC when compact target segment is not indexed", zap.Int64("child segment ID", childSegment.GetID())) return false } @@ -408,7 +408,7 @@ func (gc *garbageCollector) recycleUnusedIndexFiles() { if !canRecycle { // Even if the index is marked as deleted, the index file will not be recycled, wait for the next gc, // and delete all index files about the buildID at one time. - log.Warn("garbageCollector can not recycle index files", zap.Int64("buildID", buildID)) + log.Info("garbageCollector can not recycle index files", zap.Int64("buildID", buildID)) continue } if segIdx == nil { diff --git a/internal/datanode/flow_graph_dd_node.go b/internal/datanode/flow_graph_dd_node.go index 8135535f08..57a37de1dd 100644 --- a/internal/datanode/flow_graph_dd_node.go +++ b/internal/datanode/flow_graph_dd_node.go @@ -149,7 +149,7 @@ func (ddn *ddNode) Operate(in []Msg) []Msg { case commonpb.MsgType_DropCollection: if msg.(*msgstream.DropCollectionMsg).GetCollectionID() == ddn.collectionID { log.Info("Receiving DropCollection msg", - zap.Any("collectionID", ddn.collectionID), + zap.Int64("collectionID", ddn.collectionID), zap.String("vChannelName", ddn.vChannelName)) ddn.dropMode.Store(true) @@ -174,7 +174,7 @@ func (ddn *ddNode) Operate(in []Msg) []Msg { case commonpb.MsgType_Insert: imsg := msg.(*msgstream.InsertMsg) if imsg.CollectionID != ddn.collectionID { - log.Warn("filter invalid insert message, collection mis-match", + log.Info("filter invalid insert message, collection mis-match", zap.Int64("Get collID", imsg.CollectionID), zap.Int64("Expected collID", ddn.collectionID)) continue diff --git a/internal/proxy/privilege_interceptor.go b/internal/proxy/privilege_interceptor.go index 37a5665f99..5bff2fb200 100644 --- a/internal/proxy/privilege_interceptor.go +++ b/internal/proxy/privilege_interceptor.go @@ -69,7 +69,7 @@ func PrivilegeInterceptor(ctx context.Context, req interface{}) (context.Context log.Debug("PrivilegeInterceptor", zap.String("type", reflect.TypeOf(req).String())) privilegeExt, err := funcutil.GetPrivilegeExtObj(req) if err != nil { - log.Warn("GetPrivilegeExtObj err", zap.Error(err)) + log.Info("GetPrivilegeExtObj err", zap.Error(err)) return ctx, nil } username, err := GetCurUserFromContext(ctx) @@ -87,7 +87,7 @@ func PrivilegeInterceptorWithUsername(ctx context.Context, username string, req log.Debug("PrivilegeInterceptor", zap.String("type", reflect.TypeOf(req).String())) privilegeExt, err := funcutil.GetPrivilegeExtObj(req) if err != nil { - log.Warn("GetPrivilegeExtObj err", zap.Error(err)) + log.Info("GetPrivilegeExtObj err", zap.Error(err)) return ctx, nil } return privilegeInterceptor(ctx, privilegeExt, username, req) diff --git a/pkg/util/funcutil/policy.go b/pkg/util/funcutil/policy.go index 4b895ec64b..5405f25cc7 100644 --- a/pkg/util/funcutil/policy.go +++ b/pkg/util/funcutil/policy.go @@ -33,7 +33,7 @@ func GetVersion(m proto.GeneratedMessage) (string, error) { func GetPrivilegeExtObj(m proto.GeneratedMessage) (commonpb.PrivilegeExt, error) { _, md := descriptor.MessageDescriptorProto(m) if md == nil { - log.Warn("MessageDescriptorProto result is nil") + log.Info("MessageDescriptorProto result is nil") return commonpb.PrivilegeExt{}, fmt.Errorf("MessageDescriptorProto result is nil") }