diff --git a/internal/datacoord/channel_manager.go b/internal/datacoord/channel_manager.go index d9bf9f4339..6c4c063cfa 100644 --- a/internal/datacoord/channel_manager.go +++ b/internal/datacoord/channel_manager.go @@ -149,7 +149,7 @@ func (c *ChannelManager) bgCheckChannelsWork(ctx context.Context) { c.mu.Lock() channels := c.store.GetNodesChannels() - reallocs, err := c.bgChecker(channels, time.Now()) + reallocates, err := c.bgChecker(channels, time.Now()) if err != nil { log.Warn("channel manager bg check failed", zap.Error(err)) @@ -157,7 +157,7 @@ func (c *ChannelManager) bgCheckChannelsWork(ctx context.Context) { continue } - updates := c.reassignPolicy(c.store, reallocs) + updates := c.reassignPolicy(c.store, reallocates) log.Debug("channel manager bg check reassign", zap.Array("updates", updates)) for _, update := range updates { if update.Type == Add {