From 898533c5e4814dc518c05e54450a9166fe700ed1 Mon Sep 17 00:00:00 2001 From: congqixia Date: Fri, 1 Apr 2022 14:19:58 +0800 Subject: [PATCH] Fix Datacoord unsubAttempt using pchannel (#16337) (#16338) Fix the channel name used when Datacoord unsub for DataNode This channel shall always be pChannel instead of vChannel Signed-off-by: Congqi Xia --- internal/datacoord/channel_manager.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/internal/datacoord/channel_manager.go b/internal/datacoord/channel_manager.go index 6dd91f332..751e149cd 100644 --- a/internal/datacoord/channel_manager.go +++ b/internal/datacoord/channel_manager.go @@ -26,6 +26,7 @@ import ( "github.com/milvus-io/milvus/internal/log" "github.com/milvus-io/milvus/internal/msgstream" "github.com/milvus-io/milvus/internal/proto/datapb" + "github.com/milvus-io/milvus/internal/util/funcutil" "github.com/milvus-io/milvus/internal/util/logutil" v3rpc "go.etcd.io/etcd/api/v3/v3rpc/rpctypes" @@ -363,7 +364,9 @@ func (c *ChannelManager) unsubscribe(subName string, channel string) error { return err } - msgStream.AsConsumer([]string{channel}, subName) + pchannelName := funcutil.ToPhysicalChannel(channel) + + msgStream.AsConsumer([]string{pchannelName}, subName) msgStream.Close() return nil } -- GitLab