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) {