diff --git a/internal/datacoord/meta.go b/internal/datacoord/meta.go index 3f384758d5c7f..e1d8155b7eb62 100644 --- a/internal/datacoord/meta.go +++ b/internal/datacoord/meta.go @@ -489,7 +489,7 @@ func (m *meta) GetAllCollectionNumRows() map[int64]int64 { // AddSegment records segment info, persisting info into kv store func (m *meta) AddSegment(ctx context.Context, segment *SegmentInfo) error { - log := log.Ctx(ctx) + log := log.Ctx(ctx).With(zap.String("channel", segment.GetInsertChannel())) log.Info("meta update: adding segment - Start", zap.Int64("segmentID", segment.GetID())) m.Lock() defer m.Unlock() diff --git a/internal/querynodev2/segments/segment_l0.go b/internal/querynodev2/segments/segment_l0.go index 5119e64c66119..b1e1afdd54ccd 100644 --- a/internal/querynodev2/segments/segment_l0.go +++ b/internal/querynodev2/segments/segment_l0.go @@ -173,6 +173,13 @@ func (s *L0Segment) Release(ctx context.Context, opts ...releaseOption) { s.pks = nil s.tss = nil + + log.Ctx(ctx).Info("release L0 segment from memory", + zap.Int64("collectionID", s.Collection()), + zap.Int64("partitionID", s.Partition()), + zap.Int64("segmentID", s.ID()), + zap.String("segmentType", s.segmentType.String()), + ) } func (s *L0Segment) RemoveUnusedFieldFiles() error { diff --git a/internal/querynodev2/services.go b/internal/querynodev2/services.go index 576e549c47224..1a5d7c3a59e50 100644 --- a/internal/querynodev2/services.go +++ b/internal/querynodev2/services.go @@ -410,7 +410,7 @@ func (node *QueryNode) LoadSegments(ctx context.Context, req *querypb.LoadSegmen zap.Int64("segmentID", segment.GetSegmentID()), zap.String("level", segment.GetLevel().String()), zap.Int64("currentNodeID", node.GetNodeID()), - zap.Bool("isSorted", segment.GetIsSorted()), + zap.Int64("dstNodeID", req.GetDstNodeID()), ) log.Info("received load segments request",