From 5aa5e144cfa8fd1cdb874f645d026b62f87d795d Mon Sep 17 00:00:00 2001
From: dongmen <414110582@qq.com>
Date: Wed, 6 Mar 2024 13:06:32 +0800
Subject: [PATCH] fix kv client data race panic

---
 cdc/kv/client.go | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/cdc/kv/client.go b/cdc/kv/client.go
index 6e951b2b6b2..a2bcb05b995 100644
--- a/cdc/kv/client.go
+++ b/cdc/kv/client.go
@@ -460,6 +460,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) })
 
@@ -468,8 +469,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():