From 146a3342c3918c69cd76f068f0f8f7defada561c Mon Sep 17 00:00:00 2001 From: yah01 Date: Thu, 13 Oct 2022 15:21:23 +0800 Subject: [PATCH] Use task's ID as the MsgID instead of source ID (#19751) Signed-off-by: yah01 Signed-off-by: yah01 --- internal/querycoordv2/task/utils.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/querycoordv2/task/utils.go b/internal/querycoordv2/task/utils.go index 2bd3567f9a..f8b10769d5 100644 --- a/internal/querycoordv2/task/utils.go +++ b/internal/querycoordv2/task/utils.go @@ -80,7 +80,7 @@ func packLoadSegmentRequest( return &querypb.LoadSegmentsRequest{ Base: &commonpb.MsgBase{ MsgType: commonpb.MsgType_LoadSegments, - MsgID: task.SourceID(), + MsgID: task.ID(), }, Infos: []*querypb.SegmentLoadInfo{loadInfo}, Schema: schema, @@ -98,7 +98,7 @@ func packReleaseSegmentRequest(task *SegmentTask, action *SegmentAction) *queryp return &querypb.ReleaseSegmentsRequest{ Base: &commonpb.MsgBase{ MsgType: commonpb.MsgType_ReleaseSegments, - MsgID: task.SourceID(), + MsgID: task.ID(), }, NodeID: action.Node(), @@ -128,7 +128,7 @@ func packSubDmChannelRequest( return &querypb.WatchDmChannelsRequest{ Base: &commonpb.MsgBase{ MsgType: commonpb.MsgType_WatchDmChannels, - MsgID: task.SourceID(), + MsgID: task.ID(), }, NodeID: action.Node(), CollectionID: task.CollectionID(), @@ -171,7 +171,7 @@ func packUnsubDmChannelRequest(task *ChannelTask, action Action) *querypb.UnsubD return &querypb.UnsubDmChannelRequest{ Base: &commonpb.MsgBase{ MsgType: commonpb.MsgType_UnsubDmChannel, - MsgID: task.SourceID(), + MsgID: task.ID(), }, NodeID: action.Node(), CollectionID: task.CollectionID(),