diff --git a/pkg/tso/global_allocator.go b/pkg/tso/global_allocator.go index d79a9b2f0b7..67e398bbcee 100644 --- a/pkg/tso/global_allocator.go +++ b/pkg/tso/global_allocator.go @@ -543,6 +543,11 @@ func (gta *GlobalTSOAllocator) campaignLeader() { }() gta.member.EnableLeader() + defer resetLeaderOnce.Do(func() { + cancel() + gta.member.ResetLeader() + }) + // TODO: if enable-local-tso is true, check the cluster dc-location after the primary is elected // go gta.tsoAllocatorManager.ClusterDCLocationChecker() log.Info("tso primary is ready to serve", zap.String("tso-primary-name", gta.member.Name()))