diff --git a/cdc/processor/processor.go b/cdc/processor/processor.go index a682b05f53f..cb2a28c9b4e 100644 --- a/cdc/processor/processor.go +++ b/cdc/processor/processor.go @@ -919,7 +919,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) }