diff --git a/pkg/syncer/client.go b/pkg/syncer/client.go index 86a32e9c045..3d7f36d9114 100644 --- a/pkg/syncer/client.go +++ b/pkg/syncer/client.go @@ -156,6 +156,7 @@ func (s *RegionSyncer) StartSyncWithLeader(addr string) { log.Error("server failed to establish sync stream with leader", zap.String("server", s.server.Name()), zap.String("leader", s.server.GetLeader().GetName()), errs.ZapError(err)) select { case <-ctx.Done(): + log.Info("stop synchronizing with leader due to context canceled") return case <-time.After(retryInterval): } @@ -172,6 +173,7 @@ func (s *RegionSyncer) StartSyncWithLeader(addr string) { } select { case <-ctx.Done(): + log.Info("stop synchronizing with leader due to context canceled") return case <-time.After(retryInterval): }