@@ -5106,15 +5106,16 @@ log space");
5106
5106
// print the current replication position
5107
5107
if (mi->using_gtid == Master_info::USE_GTID_NO)
5108
5108
sql_print_information (" Slave I/O thread exiting, read up to log '%s', "
5109
- " position %llu" , IO_RPL_LOG_NAME, mi->master_log_pos );
5109
+ " position %llu, master %s:%d" , IO_RPL_LOG_NAME, mi->master_log_pos ,
5110
+ mi->host , mi->port );
5110
5111
else
5111
5112
{
5112
5113
StringBuffer<100 > tmp;
5113
5114
mi->gtid_current_pos .to_string (&tmp);
5114
5115
sql_print_information (" Slave I/O thread exiting, read up to log '%s', "
5115
- " position %llu; GTID position %s" ,
5116
+ " position %llu; GTID position %s, master %s:%d " ,
5116
5117
IO_RPL_LOG_NAME, mi->master_log_pos ,
5117
- tmp.c_ptr_safe ());
5118
+ tmp.c_ptr_safe (), mi-> host , mi-> port );
5118
5119
}
5119
5120
repl_semisync_slave.slave_stop (mi);
5120
5121
thd->reset_query ();
@@ -5717,8 +5718,9 @@ pthread_handler_t handle_slave_sql(void *arg)
5717
5718
tmp.append (STRING_WITH_LEN (" '" ));
5718
5719
}
5719
5720
sql_print_information (" Slave SQL thread exiting, replication stopped in "
5720
- " log '%s' at position %llu%s" , RPL_LOG_NAME,
5721
- rli->group_master_log_pos , tmp.c_ptr_safe ());
5721
+ " log '%s' at position %llu%s, master: %s:%d" , RPL_LOG_NAME,
5722
+ rli->group_master_log_pos , tmp.c_ptr_safe (),
5723
+ mi->host , mi->port );
5722
5724
}
5723
5725
#ifdef WITH_WSREP
5724
5726
wsrep_after_command_before_result (thd);
0 commit comments