From 5f9c7c8e02134d4551c211e9f65fa6c4ecd94f7e Mon Sep 17 00:00:00 2001 From: Ryan Leung Date: Thu, 21 Nov 2024 16:16:52 +0800 Subject: [PATCH] fix Signed-off-by: Ryan Leung --- server/region_syncer/client.go | 14 +------------- 1 file changed, 1 insertion(+), 13 deletions(-) diff --git a/server/region_syncer/client.go b/server/region_syncer/client.go index c9d9c172d3d..b44bac6ca86 100644 --- a/server/region_syncer/client.go +++ b/server/region_syncer/client.go @@ -18,6 +18,7 @@ import ( "context" "time" + "github.com/docker/go-units" "github.com/pingcap/errors" "github.com/pingcap/kvproto/pkg/metapb" "github.com/pingcap/kvproto/pkg/pdpb" @@ -38,11 +39,8 @@ import ( const ( keepaliveTime = 10 * time.Second keepaliveTimeout = 3 * time.Second -<<<<<<< HEAD:server/region_syncer/client.go -======= msgSize = 8 * units.MiB retryInterval = time.Second ->>>>>>> 41ec8dced (syncer: exit watch leader immediately (#8824)):pkg/syncer/client.go ) // StopSyncWithLeader stop to sync the region with leader. @@ -233,17 +231,7 @@ func (s *RegionSyncer) StartSyncWithLeader(addr string) { log.Debug("region is stale", zap.Stringer("origin", origin.GetMeta()), errs.ZapError(err)) continue } -<<<<<<< HEAD:server/region_syncer/client.go saveKV, _, _ := regionGuide(region, origin) -======= - cctx := &core.MetaProcessContext{ - Context: ctx, - TaskRunner: ratelimit.NewSyncRunner(), - Tracer: core.NewNoopHeartbeatProcessTracer(), - // no limit for followers. - } - saveKV, _, _, _ := regionGuide(cctx, region, origin) ->>>>>>> 41ec8dced (syncer: exit watch leader immediately (#8824)):pkg/syncer/client.go overlaps := bc.PutRegion(region) if hasBuckets {