diff --git a/internal/datacoord/channel_manager.go b/internal/datacoord/channel_manager.go index 8724d6328f..8d345eaa79 100644 --- a/internal/datacoord/channel_manager.go +++ b/internal/datacoord/channel_manager.go @@ -104,7 +104,7 @@ func (c *ChannelManager) Startup(nodes []int64) error { } } - offlines := c.getOfflines(nodes, olds) + offlines := c.getOffLines(nodes, olds) for _, n := range offlines { if err := c.DeleteNode(n); err != nil { return err @@ -187,7 +187,7 @@ func (c *ChannelManager) getNewOnlines(curr []int64, old []int64) []int64 { return ret } -func (c *ChannelManager) getOfflines(curr []int64, old []int64) []int64 { +func (c *ChannelManager) getOffLines(curr []int64, old []int64) []int64 { mcurr := make(map[int64]struct{}) ret := make([]int64, 0, len(old)) for _, n := range curr {