From a078e40ff53ff09cf0d2bed1ed0a8d20e098754b Mon Sep 17 00:00:00 2001
From: congqixia <congqi.xia@zilliz.com>
Date: Thu, 20 Apr 2023 14:46:31 +0800
Subject: [PATCH] Unwatch channel in watch buffer (#23548) (#23558)

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
---
 internal/datacoord/channel_manager.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/internal/datacoord/channel_manager.go b/internal/datacoord/channel_manager.go
index 69ef2569e4..29f4436c1d 100644
--- a/internal/datacoord/channel_manager.go
+++ b/internal/datacoord/channel_manager.go
@@ -240,7 +240,7 @@ func (c *ChannelManager) checkOldNodes(nodes []UniqueID) error {
 
 // unwatchDroppedChannels removes drops channel that are marked to drop.
 func (c *ChannelManager) unwatchDroppedChannels() {
-	nodeChannels := c.store.GetNodesChannels()
+	nodeChannels := c.store.GetChannels()
 	for _, nodeChannel := range nodeChannels {
 		for _, ch := range nodeChannel.Channels {
 			if !c.h.CheckShouldDropChannel(ch.Name, ch.CollectionID) {