diff --git a/cluster/srv_job.go b/cluster/srv_job.go index 465d5b7ad..1b8c6e8f6 100644 --- a/cluster/srv_job.go +++ b/cluster/srv_job.go @@ -1068,10 +1068,11 @@ func (server *ServerMonitor) JobReseedMysqldump(backupfile string) error { return fmt.Errorf("[%s] Error happened when unzipping backup file in backup server for reseed: %s ", server.URL, err) } - clientCmd := exec.Command(cluster.GetMysqlclientPath(), `--defaults-file=`+file, `--host=`+misc.Unbracket(server.Host), `--port=`+server.Port, `--user=`+cluster.GetDbUser(), `--force`, `--batch` /*, `--init-command=reset master;set sql_log_bin=0;set global slow_query_log=0;set global general_log=0;`*/) + clientCmd := exec.Command(cluster.GetMysqlclientPath(), `--defaults-file=`+file, `--host=`+misc.Unbracket(server.Host), `--port=`+server.Port, `--user=`+cluster.GetDbUser(), `--force`, `--batch`, `--verbose` /*, `--init-command=reset master;set sql_log_bin=0;set global slow_query_log=0;set global general_log=0;`*/) clientCmd.Stdin = io.MultiReader(bytes.NewBufferString("reset master;set sql_log_bin=0;"), &buf) - stderr, _ := clientCmd.StderrPipe() + stderr, _ := clientCmd.StdoutPipe() + clientCmd.Stderr = clientCmd.Stdout if err := clientCmd.Start(); err != nil { return fmt.Errorf("Can't start mysql client:%s at %s", err, strings.ReplaceAll(clientCmd.String(), cluster.GetDbPass(), "XXXX"))