1include/master-slave.inc 2Warnings: 3Note #### Sending passwords in plain text without SSL/TLS is extremely insecure. 4Note #### Storing MySQL user name or password information in the master info repository is not secure and is therefore not recommended. Please consider using the USER and PASSWORD connection options for START SLAVE; see the 'START SLAVE Syntax' in the MySQL Manual for more information. 5[connection master] 6create view coord_wait_list as 7SELECT id from Information_Schema.processlist 8where state like 'Waiting for Slave Worker%'; 9include/stop_slave.inc 10set @save.slave_parallel_workers= @@global.slave_parallel_workers; 11set @@global.slave_parallel_workers= 4; 12create view worker_wait_list as 13SELECT id from Information_Schema.processlist 14where state like 'Waiting for an event from Coordinator'; 15include/stop_slave.inc 16Warnings: 17Note 3084 Replication thread(s) for channel '' are already stopped. 18set @save_slave_pending_jobs_size_max = @@global.slave_pending_jobs_size_max; 19set @@global.slave_pending_jobs_size_max= 1024; 20include/start_slave.inc 21Configured number of Workers is started. 22create database d0; 23create table d0.t0 (a int auto_increment primary key, b text null) engine=innodb; 24include/sync_slave_sql_with_master.inc 25begin; 26insert into d0.t0 set a= 1; 27begin; 28commit; 29*** Coordinator must be waiting for Workers have released pending events mem *** 30rollback; 31set @@global.slave_pending_jobs_size_max= @save_slave_pending_jobs_size_max; 32drop database d0; 33include/sync_slave_sql_with_master.inc 34drop view coord_wait_list; 35drop view worker_wait_list; 36set @@global.slave_parallel_workers= @save.slave_parallel_workers; 37include/rpl_end.inc 38