Revert the logger change (#8677)

Signed-off-by: xiaofan-luan <xiaofan.luan@zilliz.com>
This commit is contained in:
Xiaofan 2021-09-27 17:37:57 +08:00 committed by GitHub
parent d0b75bd68f
commit 585989935a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
9 changed files with 20 additions and 5 deletions

View File

@ -157,7 +157,8 @@ func (node *DataNode) Register() error {
go node.StartWatchChannels(node.ctx) go node.StartWatchChannels(node.ctx)
Params.initMsgChannelSubName() Params.initMsgChannelSubName()
Params.initLogCfg() //TODO reset
//Params.initLogCfg()
log.Debug("DataNode Init", log.Debug("DataNode Init",
zap.String("MsgChannelSubName", Params.MsgChannelSubName), zap.String("MsgChannelSubName", Params.MsgChannelSubName),
) )

View File

@ -126,6 +126,8 @@ func (p *ParamTable) Init() {
p.initMinioSecretAccessKey() p.initMinioSecretAccessKey()
p.initMinioUseSSL() p.initMinioUseSSL()
p.initMinioBucketName() p.initMinioBucketName()
p.initLogCfg()
} }
// ==== DataNode internal components configs ==== // ==== DataNode internal components configs ====

View File

@ -106,7 +106,8 @@ func (i *IndexNode) Register() error {
} }
i.liveCh = i.session.Init(typeutil.IndexNodeRole, Params.IP+":"+strconv.Itoa(Params.Port), false) i.liveCh = i.session.Init(typeutil.IndexNodeRole, Params.IP+":"+strconv.Itoa(Params.Port), false)
Params.NodeID = i.session.ServerID Params.NodeID = i.session.ServerID
Params.initLogCfg() //TODO reset logger
//Params.initLogCfg()
return nil return nil
} }

View File

@ -92,6 +92,7 @@ func (pt *ParamTable) initParams() {
pt.initEtcdEndpoints() pt.initEtcdEndpoints()
pt.initMetaRootPath() pt.initMetaRootPath()
pt.initIndexRootPath() pt.initIndexRootPath()
pt.initLogCfg()
} }
func (pt *ParamTable) initMinIOAddress() { func (pt *ParamTable) initMinIOAddress() {

View File

@ -107,6 +107,8 @@ func (pt *ParamTable) Init() {
pt.initRoleName() pt.initRoleName()
pt.initMaxTaskNum() pt.initMaxTaskNum()
Params.initLogCfg()
} }
func (pt *ParamTable) InitAlias(alias string) { func (pt *ParamTable) InitAlias(alias string) {

View File

@ -100,7 +100,8 @@ func (node *Proxy) Register() error {
node.session.Init(typeutil.ProxyRole, Params.NetworkAddress, false) node.session.Init(typeutil.ProxyRole, Params.NetworkAddress, false)
Params.ProxyID = node.session.ServerID Params.ProxyID = node.session.ServerID
Params.initProxySubName() Params.initProxySubName()
Params.initLogCfg() // TODO Reset the logger
//Params.initLogCfg()
return nil return nil
} }

View File

@ -80,7 +80,7 @@ func (p *ParamTable) Init() {
panic(err) panic(err)
} }
p.BaseTable.InitLogCfg("queryCoord", 0) p.initLogCfg()
p.initQueryCoordAddress() p.initQueryCoordAddress()
p.initRoleName() p.initRoleName()
@ -237,3 +237,7 @@ func (p *ParamTable) initMinioBucketName() {
} }
p.MinioBucketName = bucketName p.MinioBucketName = bucketName
} }
func (p *ParamTable) initLogCfg() {
p.InitLogCfg("querycoord", 0)
}

View File

@ -126,6 +126,8 @@ func (p *ParamTable) Init() {
p.initSegcoreChunkRows() p.initSegcoreChunkRows()
p.initKnowhereSimdType() p.initKnowhereSimdType()
p.initLogCfg()
} }
// ---------------------------------------------------------- minio // ---------------------------------------------------------- minio

View File

@ -109,7 +109,8 @@ func (node *QueryNode) Register() error {
// This param needs valid QueryNodeID // This param needs valid QueryNodeID
Params.initMsgChannelSubName() Params.initMsgChannelSubName()
Params.initLogCfg() //TODO Reset the logger
//Params.initLogCfg()
return nil return nil
} }