From c8bf9078aee4a63028dfbfdf77ffdd9b42d96fd8 Mon Sep 17 00:00:00 2001 From: yukun Date: Thu, 24 Jun 2021 13:40:03 +0800 Subject: [PATCH] Change pchannels to vchannel in retrieveResults (#6054) Signed-off-by: fishpenguin --- internal/datacoord/server.go | 4 ++-- internal/querynode/query_collection.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) 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, },