--source include/not_group_replication_plugin.inc --let $rpl_multi_source= 1 --let $rpl_topology= 1->2,1->3,1->4,2->1,2->3,2->4,3->1,3->2,3->4 #--let $rpl_topology= 1->4 --source include/rpl_init.inc # Multisource replication is already setup. # On server 1 --let $rpl_connection_name= server_1 --source include/rpl_connection.inc create table t1(f1 int, f2 blob) engine=innodb; set binlog_format='row'; # On server 4 --let $rpl_connection_name= server_4 --source include/rpl_connection.inc stop slave; update performance_schema.setup_objects set enabled='yes', timed='yes' where object_schema='mysql'; start slave; select OBJECT_NAME, count_star, AVG_TIMER_WAIT/1024/1024/1024 from performance_schema.table_io_waits_summary_by_table where OBJECT_SCHEMA='mysql' and OBJECT_NAME ='slave_master_info'; select table_name, io_write_requests, io_write from sys.schema_table_statistics where table_name='slave_master_info'; select * from performance_schema.replication_connection_status; # On server 2 --let $rpl_connection_name= server_2 --source include/rpl_connection.inc stop slave; update performance_schema.setup_objects set enabled='yes', timed='yes' where object_schema='mysql'; start slave; select OBJECT_NAME, count_star, AVG_TIMER_WAIT/1024/1024/1024 from performance_schema.table_io_waits_summary_by_table where OBJECT_SCHEMA='mysql' and OBJECT_NAME ='slave_master_info'; select table_name, io_write_requests, io_write from sys.schema_table_statistics where table_name='slave_master_info'; select * from performance_schema.replication_connection_status; # On server 1 --let $rpl_connection_name= server_1 --source include/rpl_connection.inc insert into t1(f1) values(1),(2),(3),(4),(5); insert into t1(f1) values(1),(2),(3),(4),(5); insert into t1(f1) values(1),(2),(3),(4),(5); insert into t1(f1) values(1),(2),(3),(4),(5); insert into t1(f1) values(1),(2),(3),(4),(5); update t1 set f2=repeat('a',1024) where f2 is null; --disable_query_log --let $i=500 while($i) { --eval insert into t1(f1) values($i) --dec $i } --enable_query_log select count(*) from t1; --sleep 5 # On server 4 --let $rpl_connection_name= server_4 --source include/rpl_connection.inc select OBJECT_NAME, count_star, AVG_TIMER_WAIT/1024/1024/1024 from performance_schema.table_io_waits_summary_by_table where OBJECT_SCHEMA='mysql' and OBJECT_NAME ='slave_master_info'; select table_name, io_write_requests, io_write from sys.schema_table_statistics where table_name='slave_master_info'; select * from performance_schema.replication_connection_status; select count(*) from t1; # On server 2 --let $rpl_connection_name= server_2 --source include/rpl_connection.inc stop slave; # On server 3 --let $rpl_connection_name= server_3 --source include/rpl_connection.inc stop slave; # On server 1 --let $rpl_connection_name= server_1 --source include/rpl_connection.inc insert into t1(f1) values(1),(2),(3),(4),(5); insert into t1(f1) values(1),(2),(3),(4),(5); insert into t1(f1) values(1),(2),(3),(4),(5); insert into t1(f1) values(1),(2),(3),(4),(5); insert into t1(f1) values(1),(2),(3),(4),(5); update t1 set f2=repeat('a',1024) where f2 is null; select count(*) from t1; --sleep 5 # On server 4 --let $rpl_connection_name= server_4 --source include/rpl_connection.inc select OBJECT_NAME, count_star, AVG_TIMER_WAIT/1024/1024/1024 from performance_schema.table_io_waits_summary_by_table where OBJECT_SCHEMA='mysql' and OBJECT_NAME ='slave_master_info'; select table_name, io_write_requests, io_write from sys.schema_table_statistics where table_name='slave_master_info'; select * from performance_schema.replication_connection_status; select count(*) from t1; --sleep 5 # On server 2 --let $rpl_connection_name= server_2 --source include/rpl_connection.inc start slave; # On server 3 --let $rpl_connection_name= server_3 --source include/rpl_connection.inc start slave; --sleep 5 # On server 4 --let $rpl_connection_name= server_4 --source include/rpl_connection.inc select OBJECT_NAME, count_star, AVG_TIMER_WAIT/1024/1024/1024 from performance_schema.table_io_waits_summary_by_table where OBJECT_SCHEMA='mysql' and OBJECT_NAME ='slave_master_info'; select table_name, io_write_requests, io_write from sys.schema_table_statistics where table_name='slave_master_info'; select * from performance_schema.replication_connection_status; select count(*) from t1;