Fixbug: distinguish the name of the subscription based on ProxyID (#6333)

Signed-off-by: zhenshan.cao <zhenshan.cao@zilliz.com>
pull/6390/head
zhenshan.cao 2021-07-08 19:52:39 +08:00 committed by GitHub
parent 0d911fce1d
commit b53699b846
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 2 additions and 1 deletions

View File

@ -131,7 +131,7 @@ func (pt *ParamTable) initProxySubName() {
if err != nil {
panic(err)
}
pt.ProxySubName = prefix + "-" + pt.Alias
pt.ProxySubName = prefix + "-" + strconv.FormatInt(pt.ProxyID, 10)
}
func (pt *ParamTable) initProxyTimeTickChannelNames() {

View File

@ -96,6 +96,7 @@ func (node *Proxy) Register() error {
node.session = sessionutil.NewSession(node.ctx, Params.MetaRootPath, Params.EtcdEndpoints)
node.session.Init(typeutil.ProxyRole, Params.NetworkAddress, false)
Params.ProxyID = node.session.ServerID
Params.initProxySubName()
return nil
}