store/tikv: address comment
This commit is contained in:
@ -60,7 +60,7 @@ func (d Driver) Open(path string) (kv.Storage, error) {
|
||||
}
|
||||
|
||||
// FIXME: uuid will be a very long and ugly string, simplify it.
|
||||
uuid := fmt.Sprintf("tikv-%v", etcdAddrs)
|
||||
uuid := fmt.Sprintf("tikv-%v", pdCli.GetClusterID())
|
||||
if store, ok := mc.cache[uuid]; ok {
|
||||
return store, nil
|
||||
}
|
||||
|
||||
@ -51,7 +51,7 @@ func NewLockResolver(etcdAddrs []string) (*LockResolver, error) {
|
||||
if err != nil {
|
||||
return nil, errors.Trace(err)
|
||||
}
|
||||
uuid := fmt.Sprintf("tikv-%v", etcdAddrs)
|
||||
uuid := fmt.Sprintf("tikv-%v", pdCli.GetClusterID())
|
||||
s, err := newTikvStore(uuid, &codecPDClient{pdCli}, newRPCClient(), false)
|
||||
if err != nil {
|
||||
return nil, errors.Trace(err)
|
||||
|
||||
Reference in New Issue
Block a user