test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-01 03:18:29 +08:00
Code Issues Actions 11 Packages Projects Releases Wiki Activity

Fix log of RootCoord (#20412)

Browse Source 
Signed-off-by: longjiquan <jiquan.long@zilliz.com>

Signed-off-by: longjiquan <jiquan.long@zilliz.com>
This commit is contained in:
Jiquan Long 2022-11-09 15:07:03 +08:00 committed by GitHub
parent 2189530f5b
commit cc9dc0f0fa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
internal/rootcoord/proxy_client_manager.go
View File

@ -100,7 +100,7 @@ func (p *proxyClientManager) connect(session *sessionutil.Session) {
return
}
p.proxyClient[session.ServerID] = pc
log.Debug("succeed to create proxy client", zap.String("address", session.Address), zap.Int64("serverID", session.ServerID))
log.Info("succeed to create proxy client", zap.String("address", session.Address), zap.Int64("serverID", session.ServerID))
p.helper.afterConnect()
}
@ -114,7 +114,7 @@ func (p *proxyClientManager) DelProxyClient(s *sessionutil.Session) {
}
delete(p.proxyClient, s.ServerID)
log.Debug("remove proxy client", zap.String("proxy address", s.Address), zap.Int64("proxy id", s.ServerID))
log.Info("remove proxy client", zap.String("proxy address", s.Address), zap.Int64("proxy id", s.ServerID))
}
func (p *proxyClientManager) InvalidateCollectionMetaCache(ctx context.Context, request *proxypb.InvalidateCollMetaCacheRequest, opts ...expireCacheOpt) error {

2
internal/rootcoord/root_coord.go
View File

@ -1415,7 +1415,7 @@ func (c *Core) GetMetrics(ctx context.Context, in *milvuspb.GetMetricsRequest) (
return ret, nil
}
log.Warn("GetSystemInfoMetrics from cache failed", zap.String("role", typeutil.RootCoordRole),
log.Debug("GetSystemInfoMetrics from cache failed, recompute instead", zap.String("role", typeutil.RootCoordRole),
zap.Int64("msgID", in.GetBase().GetMsgID()), zap.Error(err))
systemInfoMetrics, err := c.getSystemInfoMetrics(ctx, in)

12
internal/rootcoord/timeticksync.go
View File

@ -114,7 +114,7 @@ func newTimeTickSync(ctx context.Context, sourceID int64, factory msgstream.Fact
// recover physical channels for all collections
for collID, chanNames := range chanMap {
dmlChannels.addChannels(chanNames...)
log.Debug("recover physical channels", zap.Int64("collID", collID), zap.Strings("physical channels", chanNames))
log.Info("recover physical channels", zap.Int64("collID", collID), zap.Strings("physical channels", chanNames))
}
return &timetickSync{
@ -208,7 +208,7 @@ func (t *timetickSync) addSession(sess *sessionutil.Session) {
t.lock.Lock()
defer t.lock.Unlock()
t.sess2ChanTsMap[sess.ServerID] = nil
log.Debug("Add session for timeticksync", zap.Int64("serverID", sess.ServerID))
log.Info("Add session for timeticksync", zap.Int64("serverID", sess.ServerID))
}
func (t *timetickSync) delSession(sess *sessionutil.Session) {
@ -216,7 +216,7 @@ func (t *timetickSync) delSession(sess *sessionutil.Session) {
defer t.lock.Unlock()
if _, ok := t.sess2ChanTsMap[sess.ServerID]; ok {
delete(t.sess2ChanTsMap, sess.ServerID)
log.Debug("Remove session from timeticksync", zap.Int64("serverID", sess.ServerID))
log.Info("Remove session from timeticksync", zap.Int64("serverID", sess.ServerID))
t.sendToChannel()
}
}
@ -228,7 +228,7 @@ func (t *timetickSync) initSessions(sess []*sessionutil.Session) {
t.sess2ChanTsMap[t.sourceID] = nil
for _, s := range sess {
t.sess2ChanTsMap[s.ServerID] = nil
log.Debug("Init proxy sessions for timeticksync", zap.Int64("serverID", s.ServerID))
log.Info("Init proxy sessions for timeticksync", zap.Int64("serverID", s.ServerID))
}
}
@ -246,11 +246,11 @@ func (t *timetickSync) startWatch(wg *sync.WaitGroup) {
for {
select {
case <-t.ctx.Done():
log.Debug("rootcoord context done", zap.Error(t.ctx.Err()))
log.Info("rootcoord context done", zap.Error(t.ctx.Err()))
return
case sessTimetick, ok := <-t.sendChan:
if !ok {
log.Debug("timetickSync sendChan closed")
log.Info("timetickSync sendChan closed")
return
}
if enableTtChecker {