diff --git a/dm/config/task.go b/dm/config/task.go index 9b18d7a457..a9db02bd2f 100644 --- a/dm/config/task.go +++ b/dm/config/task.go @@ -722,6 +722,7 @@ func checkDuplicateString(ruleNames []string) []string { // AdjustTargetDBSessionCfg adjust session cfg of TiDB func AdjustTargetDBSessionCfg(dbConfig *DBConfig, version utils.TiDBVersion) { + log.L().Info("in adjust target db session cfg") lowerMap := make(map[string]string, len(dbConfig.Session)) for k, v := range dbConfig.Session { lowerMap[strings.ToLower(k)] = v diff --git a/dm/master/server.go b/dm/master/server.go index 22c78ecef0..55d5401af3 100644 --- a/dm/master/server.go +++ b/dm/master/server.go @@ -1256,6 +1256,7 @@ func adjustTargetDB(ctx context.Context, dbConfig *config.DBConfig) error { cfg.Password = utils.DecryptOrPlaintext(cfg.Password) } + log.L().Info("in adjust target db") toDB, err := conn.DefaultDBProvider.Apply(cfg) if err != nil { return err @@ -1266,6 +1267,7 @@ func adjustTargetDB(ctx context.Context, dbConfig *config.DBConfig) error { toDB.Close() return err } + log.L().Info("get version: ", zap.String("tidb version", value)) version, err := utils.ToTiDBVersion(value) // Do not adjust if not TiDB