kv (ticdc): fix kv client data race panic (#10719)

close #10718
pingcap · Mar 6, 2024 · e9128ab · e9128ab
1 parent 9b30691
commit e9128ab
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/cdc/kv/client.go b/cdc/kv/client.go
@@ -478,6 +478,7 @@ func (s *eventFeedSession) eventFeed(ctx context.Context) error {
 	}()
 
 	g, ctx := errgroup.WithContext(ctx)
+	g.SetLimit(scanRegionsConcurrency)
 
 	g.Go(func() error { return s.dispatchRequest(ctx) })
 
@@ -486,8 +487,6 @@ 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():