diff --git a/bin/pt-table-sync b/bin/pt-table-sync index 0f33afab3..62cbd684b 100755 --- a/bin/pt-table-sync +++ b/bin/pt-table-sync @@ -6776,7 +6776,7 @@ sub recurse_to_slaves { my $slave_dsn = $dsn; if ($slave_user) { $slave_dsn->{u} = $slave_user; - PTDEBUG && _d("Using slave user $slave_user on ".$slave_dsn->{h}.":".$slave_dsn->{P}); + PTDEBUG && _d("Using slave user $slave_user on ".$dp->as_string($slave_dsn)); } if ($slave_password) { $slave_dsn->{p} = $slave_password; @@ -6823,7 +6823,7 @@ sub recurse_to_slaves { PTDEBUG && _d('Recursing from', $dp->as_string($dsn), 'to', $dp->as_string($slave)); $self->recurse_to_slaves( - { %$args, dsn => $slave, dbh => undef, parent => $dsn, slave_user => $slave_user, $slave_password => $slave_password }, $level + 1 ); + { %$args, dsn => $slave, dbh => undef, parent => $dsn, slave_user => $slave_user, slave_password => $slave_password }, $level + 1 ); } } } @@ -10418,6 +10418,8 @@ sub sync_via_replication { $ms->recurse_to_slaves( { dbh => $src->{dbh}, dsn => $src->{dsn}, + slave_user => $o->got('slave-user') ? $o->get('slave-user') : '', + slave_password => $o->got('slave-password') ? $o->get('slave-password') : '', recurse => 1, callback => sub { my ( $dsn, $dbh, $level, $parent ) = @_;