This is an automated cherry-pick of pingcap#10170

Signed-off-by: ti-chi-bot <ti-community-prow-bot@tidb.io>
ti-chi-bot · Nov 29, 2023 · 2fcb759 · 2fcb759
1 parent 8fb72da
commit 2fcb759
Show file tree

Hide file tree

Showing 4 changed files with 934 additions and 0 deletions.
diff --git a/cdc/kv/client.go b/cdc/kv/client.go
@@ -72,7 +72,11 @@ const (
 	// don't need to force reload region anymore.
 	regionScheduleReload = false
 
+<<<<<<< HEAD
 	resolveLockMinInterval = 10 * time.Second
+=======
+	scanRegionsConcurrency = 1024
+>>>>>>> eb96b9604f (cdc: fixes minor bugs #10168 and #10169 (#10170))
 )
 
 // time interval to force kv client to terminate gRPC stream and reconnect
@@ -432,6 +436,8 @@ func (s *eventFeedSession) eventFeed(ctx context.Context) error {
 	g.Go(func() error { return s.logSlowRegions(ctx) })
 
 	g.Go(func() error {
+		g, ctx := errgroup.WithContext(ctx)
+		g.SetLimit(scanRegionsConcurrency)
 		for {
 			select {
 			case <-ctx.Done():