sink(ticdc): add max allowed packet parmameters in sink dsn (pingcap#…

…8627) close pingcap#8622
3AceShowHand · Apr 3, 2023 · 16ff3a2 · 16ff3a2
1 parent 4d37629
commit 16ff3a2
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/sink/mysql/db_helper.go b/pkg/sink/mysql/db_helper.go
@@ -118,6 +118,8 @@ func generateDSNByConfig(
 	dsnCfg.Params["readTimeout"] = cfg.ReadTimeout
 	dsnCfg.Params["writeTimeout"] = cfg.WriteTimeout
 	dsnCfg.Params["timeout"] = cfg.DialTimeout
+	// auto fetch max_allowed_packet on every new connection
+	dsnCfg.Params["maxAllowedPacket"] = "0"
 
 	autoRandom, err := checkTiDBVariable(ctx, testDB, "allow_auto_random_explicit_insert", "1")
 	if err != nil {