mirror of https://github.com/milvus-io/milvus.git
[skip e2e]Fix variable typo (#14325)
Signed-off-by: godchen0212 <qingxiang.chen@zilliz.com>pull/14692/head
parent
f0e6e190df
commit
d7da870cc4
|
@ -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 {
|
||||
|
|
Loading…
Reference in New Issue