cdc: fixes minor bugs pingcap#10168 and pingcap#10169 (pingcap#10170)

Signed-off-by: qupeng <qupeng@pingcap.com>

cdc/kv/client.go

@@ -73,6 +73,8 @@ const (
  regionScheduleReload = false
 
  resolveLockMinInterval = 10 * time.Second
+
+ scanRegionsConcurrency = 1024
 )
 
 // time interval to force kv client to terminate gRPC stream and reconnect
@@ -432,6 +434,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():

cdc/processor/sinkmanager/tasks.go

@@ -33,8 +33,8 @@ var (
  maxUpdateIntervalSize = defaultMaxUpdateIntervalSize
 
  // Sink manager schedules table tasks based on lag. Limit the max task range
- // can be helpful to reduce changefeed latency.
- maxTaskRange = 5 * time.Second
+ // can be helpful to reduce changefeed latency for large initial data.
+ maxTaskRange = 30 * time.Minute
 )
 
 // Used to record the progress of the table.