diff --git a/cdc/processor/processor.go b/cdc/processor/processor.go index 21f7c284eb2..4588d792e4c 100644 --- a/cdc/processor/processor.go +++ b/cdc/processor/processor.go @@ -699,7 +699,7 @@ func (p *processor) createTablePipelineImpl(ctx cdcContext.Context, tableID mode } markTableID = tableInfo.ID return nil - }, retry.WithBackoffMaxDelay(50), retry.WithBackoffMaxDelay(60*1000), retry.WithMaxTries(20)) + }, retry.WithBackoffBaseDelay(50), retry.WithBackoffMaxDelay(60*1000), retry.WithMaxTries(20)) if err != nil { return nil, errors.Trace(err) }