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

close pingcap#10168
hicqu · Dec 5, 2023 · 3f6a94c · 3f6a94c
1 parent 645d825
commit 3f6a94c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/cdc/processor/sinkmanager/tasks.go b/cdc/processor/sinkmanager/tasks.go
@@ -39,8 +39,8 @@ var (
  maxUpdateIntervalSize = defaultMaxUpdateIntervalSize
 
  // Sink manager schedules table tasks based on lag. Limit the max task range
- // can be helpful to reduce changefeed latency.
- maxTaskTimeRange = 5 * time.Second
+ // can be helpful to reduce changefeed latency for large initial data.
+ maxTaskTimeRange = 30 * time.Minute
 )
 
 // Used to record the progress of the table.

diff --git a/cdc/processor/sinkmanager/tasks_test.go b/cdc/processor/sinkmanager/tasks_test.go
@@ -37,7 +37,7 @@ func TestValidateAndAdjustBound(t *testing.T) {
  StartTs: 439333515018895365,
  CommitTs: 439333515018895366,
  },
- taskTimeRange: 10 * time.Second,
+ taskTimeRange: 60 * time.Minute,
  expectAdjust: true,
  },
  {