--disable_warnings --connect (conn1,127.0.0.1,root,,test,$MYPORT_1) --connect (conn2,127.0.0.1,root,,test,$MYPORT_2) --connection conn1 stop slave; change master to master_host = '127.0.0.1', master_port = 7806, master_user = 'repl', master_password = '123456' for channel 'aaa'; start slave for channel 'aaa'; stop slave; start slave; stop slave for channel "aaa"; start slave for channel "aaa"; --error ER_CONSENSUS_SERVER_NOT_READY stop xpaxos_replication; --error ER_CONSENSUS_SERVER_NOT_READY start xpaxos_replication; stop slave; reset slave all for channel 'aaa'; --connection conn2 stop xpaxos_replication; reset slave; # # mysql> show consensus logs; # +-------------------+-----------+-----------------+ # | Log_name | File_size | Start_log_index | # +-------------------+-----------+-----------------+ # | master-bin.000001 | 1268 | 1 | # | master-bin.000002 | 252 | 5 | # +-------------------+-----------+-----------------+ # # --replace_column 1 # 2 # 3 # # show consensus logs; start xpaxos_replication; --error ER_SLAVE_CHANNEL_DOES_NOT_EXIST start slave for channel ''; --error ER_SLAVE_CHANNEL_DOES_NOT_EXIST stop slave for channel ''; --let $sql_running= query_get_value("show slave status", Slave_SQL_Running, 1) --echo $sql_running --let $sql_running= query_get_value("show slave status for channel ''", Slave_SQL_Running, 1) --echo $sql_running --enable_warnings --connection conn1 --error ER_CHANGE_RPL_INFO_REPOSITORY_FAILURE set global relay_log_info_repository='file'; set global relay_log_info_repository='table'; select count(1) from mysql.slave_relay_log_info where number_of_workers = (select count(1) from mysql.slave_worker_info); --connection conn2 --error ER_SLAVE_CHANNEL_MUST_STOP set global relay_log_info_repository='file'; stop xpaxos_replication; set global relay_log_info_repository='file'; set global relay_log_info_repository='table'; start xpaxos_replication; select count(1) from mysql.slave_relay_log_info where number_of_workers = (select count(1) from mysql.slave_worker_info);