diff --git a/internal/datacoord/server.go b/internal/datacoord/server.go index f8edb3d23c..aa67c78df8 100644 --- a/internal/datacoord/server.go +++ b/internal/datacoord/server.go @@ -319,8 +319,8 @@ func (s *Server) startDataNodeTtLoop(ctx context.Context) { ch := ttMsg.ChannelName ts := ttMsg.Timestamp - log.Debug("Receive datanode timetick msg", zap.String("channel", ch), - zap.Any("ts", ts)) + // log.Debug("Receive datanode timetick msg", zap.String("channel", ch), + // zap.Any("ts", ts)) segments, err := s.segmentManager.GetFlushableSegments(ctx, ch, ts) if err != nil { log.Warn("get flushable segments failed", zap.Error(err)) diff --git a/internal/querynode/query_collection.go b/internal/querynode/query_collection.go index c6028e0216..3e66739b8b 100644 --- a/internal/querynode/query_collection.go +++ b/internal/querynode/query_collection.go @@ -1247,7 +1247,7 @@ func (q *queryCollection) retrieve(retrieveMsg *msgstream.RetrieveMsg) error { FieldsData: result.FieldsData, ResultChannelID: retrieveMsg.ResultChannelID, SealedSegmentIDsRetrieved: sealedSegmentRetrieved, - ChannelIDsRetrieved: collection.getPChannels(), + ChannelIDsRetrieved: collection.getVChannels(), //TODO(yukun):: get global sealed segment from etcd GlobalSealedSegmentIDs: sealedSegmentRetrieved, },