diff --git a/client/tso_client.go b/client/tso_client.go index d4dfaa03a91..e0b0579bbfc 100644 --- a/client/tso_client.go +++ b/client/tso_client.go @@ -209,7 +209,7 @@ func (c *tsoClient) updateTSOLocalServAddrs(allocatorMap map[string]string) erro return err } c.tsoAllocators.Store(dcLocation, addr) - log.Info("[tso] switch dc tso allocator serving address", + log.Info("[tso] switch dc tso local allocator serving address", zap.String("dc-location", dcLocation), zap.String("new-address", addr), zap.String("old-address", oldAddr)) @@ -227,7 +227,7 @@ func (c *tsoClient) updateTSOLocalServAddrs(allocatorMap map[string]string) erro func (c *tsoClient) updateTSOGlobalServAddr(addr string) error { c.tsoAllocators.Store(globalDCLocation, addr) - log.Info("[tso] switch dc tso allocator serving address", + log.Info("[tso] switch dc tso global allocator serving address", zap.String("dc-location", globalDCLocation), zap.String("new-address", addr)) c.scheduleCheckTSODispatcher() diff --git a/pkg/keyspace/tso_keyspace_group.go b/pkg/keyspace/tso_keyspace_group.go index c5e78d6b797..e6961bf1ce8 100644 --- a/pkg/keyspace/tso_keyspace_group.go +++ b/pkg/keyspace/tso_keyspace_group.go @@ -639,6 +639,7 @@ func (m *GroupManager) FinishSplitKeyspaceByID(splitTargetID uint32) error { // Update the keyspace group cache. m.groups[endpoint.StringUserKind(splitTargetKg.UserKind)].Put(splitTargetKg) m.groups[endpoint.StringUserKind(splitSourceKg.UserKind)].Put(splitSourceKg) + log.Info("finish split keyspace group", zap.Uint32("split-source-id", splitSourceKg.ID), zap.Uint32("split-target-id", splitTargetID)) return nil }