milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[skip ci]Remove redundancy log (#11732) 

Signed-off-by: sunby <bingyi.sun@zilliz.com>

Co-authored-by: sunby <bingyi.sun@zilliz.com>
pull/11633/head
Bingyi Sun 2021-11-15 10:25:09 +08:00 committed by GitHub
parent ad2572d0ef
commit 902e856a06
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
internal/datacoord/channel_manager.go
View File

@ -182,13 +182,11 @@ func (c *ChannelManager) AddNode(nodeID int64) error {
c.mu.Lock()
defer c.mu.Unlock()
channels := c.store.GetChannels()
c.store.Add(nodeID)
updates := c.registerPolicy(c.store, nodeID)
log.Debug("register node",
zap.Int64("registered node", nodeID),
zap.Any("channels before registry", channels),
zap.Array("updates", updates))
for _, v := range updates {
@ -204,12 +202,9 @@ func (c *ChannelManager) DeleteNode(nodeID int64) error {
c.mu.Lock()
defer c.mu.Unlock()
channels := c.store.GetChannels()
updates := c.deregisterPolicy(c.store, nodeID)
log.Debug("deregister node",
zap.Int64("unregistered node", nodeID),
zap.Any("channels before deregistery", channels),
zap.Array("updates", updates))
for _, v := range updates {
@ -229,15 +224,12 @@ func (c *ChannelManager) Watch(ch *channel) error {
c.mu.Lock()
defer c.mu.Unlock()
channels := c.store.GetChannels()
updates := c.assignPolicy(c.store, []*channel{ch})
if len(updates) == 0 {
return nil
}
log.Debug("watch channel",
zap.Any("channel", ch),
zap.Any("channels before watching", channels),
zap.Array("updates", updates))
for _, v := range updates {