diff --git a/bin/pt-archiver b/bin/pt-archiver index 2cef0c15..070ef48a 100755 --- a/bin/pt-archiver +++ b/bin/pt-archiver @@ -7287,9 +7287,11 @@ sub do_with_retries { $success = $OUT_OF_RETRIES; } $get_sth->finish; - trace('rollback', sub { - $dst->{dbh}->rollback; - }); + if ( $dst && $dst->{dbh} ) { + trace('rollback', sub { + $dst->{dbh}->rollback; + }); + } trace('rollback', sub { $src->{dbh}->rollback; });