RetryTxLimit: default 5 #1050

and add an 1ms delay before retry.

Author: ffffwh

driver/driver.go

@@ -163,7 +163,7 @@ var (
 		"BulkInsert3": hclspec.NewDefault(hclspec.NewAttr("BulkInsert3", "number", false),
 			hclspec.NewLiteral(`128`)),
 		"RetryTxLimit": hclspec.NewDefault(hclspec.NewAttr("RetryTxLimit", "number", false),
-			hclspec.NewLiteral(`3`)),
+			hclspec.NewLiteral(`5`)),
 		"BigTxSrcQueue": hclspec.NewDefault(hclspec.NewAttr("BigTxSrcQueue", "number", false),
 			hclspec.NewLiteral(`3`)),
 		"KafkaConfig": hclspec.NewBlock("KafkaConfig", false, hclspec.NewObject(map[string]*hclspec.Spec{

driver/mysql/applier.go

@@ -40,6 +40,7 @@ import (
 const (
 	cleanupGtidExecutedLimit = 2048
 	pingInterval             = 10 * time.Second
+	retryTxDelay             = 1 * time.Millisecond
 	JobIncrCopy              = "job_stage_incr"
 	JobFullCopy              = "job_stage_full"
 )

driver/mysql/applier_incr.go

@@ -241,6 +241,7 @@ func (a *ApplierIncr) MtsWorker(workerIndex int) {
 						if merr.Number == sql.ErrLockDeadlock && iTry < a.mysqlContext.RetryTxLimit {
 							logger.Info("found deadlock. will retry tx", "gno", entryContext.Entry.Coordinates.GetGNO(),
 								"iTry", iTry)
+							time.Sleep(retryTxDelay)
 							continue
 						}
 					}