From e49df11942ca03ff17b6dff940cb613e80aae861 Mon Sep 17 00:00:00 2001 From: "yihao.dai" Date: Wed, 24 May 2023 14:29:29 +0800 Subject: [PATCH] Fix QueryNode is not able to recovery (#24335) Signed-off-by: bigsheeper --- internal/proto/query_coord.proto | 8 ++++---- internal/querynodev2/services.go | 2 ++ 2 files changed, 6 insertions(+), 4 deletions(-) diff --git a/internal/proto/query_coord.proto b/internal/proto/query_coord.proto index c6f67662c1..5f74fe393c 100644 --- a/internal/proto/query_coord.proto +++ b/internal/proto/query_coord.proto @@ -217,9 +217,9 @@ message WatchDmChannelsRequest { int64 collectionID = 3; repeated int64 partitionIDs = 4; repeated data.VchannelInfo infos = 5; - schema.CollectionSchema schema = 6; // keep it for compatibility of rolling upgrade from 2.2.x to 2.3 + schema.CollectionSchema schema = 6; repeated data.SegmentInfo exclude_infos = 7; - LoadMetaInfo load_meta = 8; // keep it for compatibility of rolling upgrade from 2.2.x to 2.3 + LoadMetaInfo load_meta = 8; int64 replicaID = 9; map segment_infos = 10; // Deprecated @@ -277,10 +277,10 @@ message LoadSegmentsRequest { common.MsgBase base = 1; int64 dst_nodeID = 2; repeated SegmentLoadInfo infos = 3; - schema.CollectionSchema schema = 4; // keep it for compatibility of rolling upgrade from 2.2.x to 2.3 + schema.CollectionSchema schema = 4; int64 source_nodeID = 5; int64 collectionID = 6; - LoadMetaInfo load_meta = 7; // keep it for compatibility of rolling upgrade from 2.2.x to 2.3 + LoadMetaInfo load_meta = 7; int64 replicaID = 8; repeated msg.MsgPosition delta_positions = 9; // keep it for compatibility of rolling upgrade from 2.2.x to 2.3 int64 version = 10; diff --git a/internal/querynodev2/services.go b/internal/querynodev2/services.go index 8bf7cadfda..e6dc8374ab 100644 --- a/internal/querynodev2/services.go +++ b/internal/querynodev2/services.go @@ -1209,6 +1209,8 @@ func (node *QueryNode) SyncDistribution(ctx context.Context, req *querypb.SyncDi commonpbutil.WithMsgID(req.Base.GetMsgID()), ), Infos: infos, + Schema: req.GetSchema(), + LoadMeta: req.GetLoadMeta(), CollectionID: req.GetCollectionID(), ReplicaID: req.GetReplicaID(), DstNodeID: nodeID,