diff --git a/internal/datacoord/channel_manager.go b/internal/datacoord/channel_manager.go index ad731bfc4e..e00b66b085 100644 --- a/internal/datacoord/channel_manager.go +++ b/internal/datacoord/channel_manager.go @@ -85,7 +85,7 @@ func NewChannelManager(kv kv.TxnKV, posProvider positionProvider, options ...Cha return c, nil } -// Startup adjust the channel store according to current cluster states +// Startup adjusts the channel store according to current cluster states func (c *ChannelManager) Startup(nodes []int64) error { channels := c.store.GetNodesChannels() olds := make([]int64, 0, len(channels))