Reduce log volumes of DC&DN (#26060)

See also: #26057
Signed-off-by: Nyangxuan <xuan.yang@zilliz.com>

internal/datacoord/services.go

@@ -658,7 +658,11 @@ func (s *Server) GetRecoveryInfo(ctx context.Context, req *datapb.GetRecoveryInf
 		channelInfo := s.handler.GetQueryVChanPositions(&channel{Name: c, CollectionID: collectionID}, partitionID)
 		channelInfos = append(channelInfos, channelInfo)
 		log.Info("datacoord append channelInfo in GetRecoveryInfo",
-			zap.Any("channelInfo", channelInfo),
+			zap.String("channel", channelInfo.GetChannelName()),
+			zap.Int("# of unflushed segments", len(channelInfo.GetUnflushedSegmentIds())),
+			zap.Int("# of flushed segments", len(channelInfo.GetFlushedSegmentIds())),
+			zap.Int("# of dropped segments", len(channelInfo.GetDroppedSegmentIds())),
+			zap.Int("# of indexed segments", len(channelInfo.GetIndexedSegmentIds())),
 		)
 		flushedIDs.Insert(channelInfo.GetFlushedSegmentIds()...)
 	}
@@ -789,7 +793,11 @@ func (s *Server) GetRecoveryInfoV2(ctx context.Context, req *datapb.GetRecoveryI
 		channelInfo := s.handler.GetQueryVChanPositions(&channel{Name: c, CollectionID: collectionID}, partitionIDs...)
 		channelInfos = append(channelInfos, channelInfo)
 		log.Info("datacoord append channelInfo in GetRecoveryInfo",
-			zap.Any("channelInfo", channelInfo),
+			zap.String("channel", channelInfo.GetChannelName()),
+			zap.Int("# of unflushed segments", len(channelInfo.GetUnflushedSegmentIds())),
+			zap.Int("# of flushed segments", len(channelInfo.GetFlushedSegmentIds())),
+			zap.Int("# of dropped segments", len(channelInfo.GetDroppedSegmentIds())),
+			zap.Int("# of indexed segments", len(channelInfo.GetIndexedSegmentIds())),
 		)
 		flushedIDs.Insert(channelInfo.GetFlushedSegmentIds()...)
 	}

internal/datanode/services.go

@@ -28,6 +28,7 @@ import (
 
 	"github.com/cockroachdb/errors"
 	"github.com/milvus-io/milvus/pkg/util/tsoutil"
+	"github.com/samber/lo"
 	"go.uber.org/zap"
 
 	"github.com/milvus-io/milvus-proto/go-api/v2/commonpb"
@@ -327,7 +328,10 @@ func (node *DataNode) GetCompactionState(ctx context.Context, req *datapb.Compac
 	})
 
 	if len(results) > 0 {
-		log.Info("Compaction results", zap.Any("results", results))
+		planIDs := lo.Map(results, func(result *datapb.CompactionStateResult, i int) UniqueID {
+			return result.GetPlanID()
+		})
+		log.Info("Compaction results", zap.Int64s("planIDs", planIDs))
 	}
 	return &datapb.CompactionStateResponse{
 		Status:  merr.Status(nil),