include/rpl_init.inc [topology=1->2]
SET @old_parallel_threads=@@GLOBAL.slave_parallel_threads;
SET GLOBAL slave_parallel_threads=10;
ERROR HY000: This operation cannot be performed as you have a running slave ''; run STOP SLAVE '' first
include/stop_slave.inc
SET GLOBAL slave_parallel_threads=10;
CHANGE MASTER TO master_use_gtid=slave_pos;
include/start_slave.inc
*** Test long-running query in domain 1 can run in parallel with short queries in domain 0 ***
ALTER TABLE mysql.gtid_slave_pos ENGINE=InnoDB;
CREATE TABLE t1 (a int PRIMARY KEY) ENGINE=MyISAM;
CREATE TABLE t2 (a int PRIMARY KEY) ENGINE=InnoDB;
INSERT INTO t1 VALUES (1);
INSERT INTO t2 VALUES (1);
LOCK TABLE t1 WRITE;
SET gtid_domain_id=1;
INSERT INTO t1 VALUES (2);
SET gtid_domain_id=0;
INSERT INTO t2 VALUES (2);
INSERT INTO t2 VALUES (3);
BEGIN;
INSERT INTO t2 VALUES (4);
INSERT INTO t2 VALUES (5);
COMMIT;
INSERT INTO t2 VALUES (6);
SELECT * FROM t2 ORDER by a;
a
1
2
3
4
5
6
SELECT * FROM t1;
a
1
UNLOCK TABLES;
SELECT * FROM t1 ORDER BY a;
a
1
2
*** Test two transactions in different domains committed in opposite order on slave but in a single group commit. ***
include/stop_slave.inc
SET sql_log_bin=0;
CREATE FUNCTION foo(x INT, d1 VARCHAR(500), d2 VARCHAR(500))
RETURNS INT DETERMINISTIC
BEGIN
RETURN x;
END
||
SET sql_log_bin=1;
SET @old_format= @@SESSION.binlog_format;
SET binlog_format='statement';
SET gtid_domain_id=1;
INSERT INTO t2 VALUES (foo(10,
'commit_before_enqueue SIGNAL ready1 WAIT_FOR cont1',
'commit_after_release_LOCK_prepare_ordered SIGNAL ready2'));
FLUSH LOGS;
SET sql_log_bin=0;
CREATE FUNCTION foo(x INT, d1 VARCHAR(500), d2 VARCHAR(500))
RETURNS INT DETERMINISTIC
BEGIN
IF d1 != '' THEN
SET debug_sync = d1;
END IF;
IF d2 != '' THEN
SET debug_sync = d2;
END IF;
RETURN x;
END
||
SET sql_log_bin=1;
SET @old_format=@@GLOBAL.binlog_format;
SET GLOBAL binlog_format=statement;
SET GLOBAL slave_parallel_threads=0;
SET GLOBAL slave_parallel_threads=10;
include/start_slave.inc
SET debug_sync='now WAIT_FOR ready1';
SET gtid_domain_id=2;
INSERT INTO t2 VALUES (foo(11,
'commit_before_enqueue SIGNAL ready3 WAIT_FOR cont3',
'commit_after_release_LOCK_prepare_ordered SIGNAL ready4 WAIT_FOR cont4'));
SET gtid_domain_id=0;
SELECT * FROM t2 WHERE a >= 10 ORDER BY a;
a
10
11
SET debug_sync='now WAIT_FOR ready3';
SET debug_sync='now SIGNAL cont3';
SET debug_sync='now WAIT_FOR ready4';
SET debug_sync='now SIGNAL cont1';
SET debug_sync='now WAIT_FOR ready2';
SET debug_sync='now SIGNAL cont4';
SELECT * FROM t2 WHERE a >= 10 ORDER BY a;
a
10
11
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
slave-bin.000002	#	Binlog_checkpoint	#	#	slave-bin.000002
slave-bin.000002	#	Gtid	#	#	BEGIN GTID #-#-# cid=#
slave-bin.000002	#	Query	#	#	use `test`; INSERT INTO t2 VALUES (foo(11,
'commit_before_enqueue SIGNAL ready3 WAIT_FOR cont3',
'commit_after_release_LOCK_prepare_ordered SIGNAL ready4 WAIT_FOR cont4'))
slave-bin.000002	#	Xid	#	#	COMMIT /* XID */
slave-bin.000002	#	Gtid	#	#	BEGIN GTID #-#-# cid=#
slave-bin.000002	#	Query	#	#	use `test`; INSERT INTO t2 VALUES (foo(10,
'commit_before_enqueue SIGNAL ready1 WAIT_FOR cont1',
'commit_after_release_LOCK_prepare_ordered SIGNAL ready2'))
slave-bin.000002	#	Xid	#	#	COMMIT /* XID */
FLUSH LOGS;
include/stop_slave.inc
SET GLOBAL slave_parallel_threads=0;
SET GLOBAL slave_parallel_threads=10;
SET debug_sync='RESET';
include/start_slave.inc
*** Test that group-committed transactions on the master can replicate in parallel on the slave. ***
FLUSH LOGS;
CREATE TABLE t3 (a INT PRIMARY KEY, b INT) ENGINE=InnoDB;
INSERT INTO t3 VALUES (1,1), (3,3), (5,5), (7,7);
BEGIN;
INSERT INTO t3 VALUES (2,102);
BEGIN;
INSERT INTO t3 VALUES (4,104);
SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued1 WAIT_FOR master_cont1';
SET binlog_format=statement;
INSERT INTO t3 VALUES (2, foo(12,
'commit_after_release_LOCK_prepare_ordered SIGNAL slave_queued1 WAIT_FOR slave_cont1',
''));
SET debug_sync='now WAIT_FOR master_queued1';
SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued2';
SET binlog_format=statement;
INSERT INTO t3 VALUES (4, foo(14,
'commit_after_release_LOCK_prepare_ordered SIGNAL slave_queued2',
''));
SET debug_sync='now WAIT_FOR master_queued2';
SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued3';
SET binlog_format=statement;
INSERT INTO t3 VALUES (6, foo(16,
'group_commit_waiting_for_prior SIGNAL slave_queued3',
''));
SET debug_sync='now WAIT_FOR master_queued3';
SET debug_sync='now SIGNAL master_cont1';
SELECT * FROM t3 ORDER BY a;
a	b
1	1
2	12
3	3
4	14
5	5
6	16
7	7
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000002	#	Binlog_checkpoint	#	#	master-bin.000002
master-bin.000002	#	Gtid	#	#	GTID #-#-#
master-bin.000002	#	Query	#	#	use `test`; CREATE TABLE t3 (a INT PRIMARY KEY, b INT) ENGINE=InnoDB
master-bin.000002	#	Gtid	#	#	BEGIN GTID #-#-#
master-bin.000002	#	Query	#	#	use `test`; INSERT INTO t3 VALUES (1,1), (3,3), (5,5), (7,7)
master-bin.000002	#	Xid	#	#	COMMIT /* XID */
master-bin.000002	#	Gtid	#	#	BEGIN GTID #-#-# cid=#
master-bin.000002	#	Query	#	#	use `test`; INSERT INTO t3 VALUES (2, foo(12,
'commit_after_release_LOCK_prepare_ordered SIGNAL slave_queued1 WAIT_FOR slave_cont1',
''))
master-bin.000002	#	Xid	#	#	COMMIT /* XID */
master-bin.000002	#	Gtid	#	#	BEGIN GTID #-#-# cid=#
master-bin.000002	#	Query	#	#	use `test`; INSERT INTO t3 VALUES (4, foo(14,
'commit_after_release_LOCK_prepare_ordered SIGNAL slave_queued2',
''))
master-bin.000002	#	Xid	#	#	COMMIT /* XID */
master-bin.000002	#	Gtid	#	#	BEGIN GTID #-#-# cid=#
master-bin.000002	#	Query	#	#	use `test`; INSERT INTO t3 VALUES (6, foo(16,
'group_commit_waiting_for_prior SIGNAL slave_queued3',
''))
master-bin.000002	#	Xid	#	#	COMMIT /* XID */
SET debug_sync='now WAIT_FOR slave_queued3';
ROLLBACK;
SET debug_sync='now WAIT_FOR slave_queued1';
ROLLBACK;
SET debug_sync='now WAIT_FOR slave_queued2';
SET debug_sync='now SIGNAL slave_cont1';
SELECT * FROM t3 ORDER BY a;
a	b
1	1
2	12
3	3
4	14
5	5
6	16
7	7
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
slave-bin.000003	#	Binlog_checkpoint	#	#	slave-bin.000003
slave-bin.000003	#	Gtid	#	#	GTID #-#-#
slave-bin.000003	#	Query	#	#	use `test`; CREATE TABLE t3 (a INT PRIMARY KEY, b INT) ENGINE=InnoDB
slave-bin.000003	#	Gtid	#	#	BEGIN GTID #-#-#
slave-bin.000003	#	Query	#	#	use `test`; INSERT INTO t3 VALUES (1,1), (3,3), (5,5), (7,7)
slave-bin.000003	#	Xid	#	#	COMMIT /* XID */
slave-bin.000003	#	Gtid	#	#	BEGIN GTID #-#-# cid=#
slave-bin.000003	#	Query	#	#	use `test`; INSERT INTO t3 VALUES (2, foo(12,
'commit_after_release_LOCK_prepare_ordered SIGNAL slave_queued1 WAIT_FOR slave_cont1',
''))
slave-bin.000003	#	Xid	#	#	COMMIT /* XID */
slave-bin.000003	#	Gtid	#	#	BEGIN GTID #-#-# cid=#
slave-bin.000003	#	Query	#	#	use `test`; INSERT INTO t3 VALUES (4, foo(14,
'commit_after_release_LOCK_prepare_ordered SIGNAL slave_queued2',
''))
slave-bin.000003	#	Xid	#	#	COMMIT /* XID */
slave-bin.000003	#	Gtid	#	#	BEGIN GTID #-#-# cid=#
slave-bin.000003	#	Query	#	#	use `test`; INSERT INTO t3 VALUES (6, foo(16,
'group_commit_waiting_for_prior SIGNAL slave_queued3',
''))
slave-bin.000003	#	Xid	#	#	COMMIT /* XID */
*** Test STOP SLAVE in parallel mode ***
include/stop_slave.inc
SET binlog_direct_non_transactional_updates=0;
SET sql_log_bin=0;
CALL mtr.add_suppression("Statement is unsafe because it accesses a non-transactional table after accessing a transactional table within the same transaction");
SET sql_log_bin=1;
BEGIN;
INSERT INTO t2 VALUES (20);
INSERT INTO t1 VALUES (20);
INSERT INTO t2 VALUES (21);
INSERT INTO t3 VALUES (20, 20);
COMMIT;
INSERT INTO t3 VALUES(21, 21);
INSERT INTO t3 VALUES(22, 22);
SET binlog_format=@old_format;
BEGIN;
INSERT INTO t2 VALUES  (21);
START SLAVE;
STOP SLAVE;
ROLLBACK;
include/wait_for_slave_to_stop.inc
SELECT * FROM t1 WHERE a >= 20 ORDER BY a;
a
20
SELECT * FROM t2 WHERE a >= 20 ORDER BY a;
a
20
21
SELECT * FROM t3 WHERE a >= 20 ORDER BY a;
a	b
20	20
include/start_slave.inc
SELECT * FROM t1 WHERE a >= 20 ORDER BY a;
a
20
SELECT * FROM t2 WHERE a >= 20 ORDER BY a;
a
20
21
SELECT * FROM t3 WHERE a >= 20 ORDER BY a;
a	b
20	20
21	21
22	22
include/stop_slave.inc
SET GLOBAL binlog_format=@old_format;
SET GLOBAL slave_parallel_threads=0;
SET GLOBAL slave_parallel_threads=10;
include/start_slave.inc
*** Test killing slave threads at various wait points ***
*** 1. Test killing transaction waiting in commit for previous transaction to commit ***
SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued1 WAIT_FOR master_cont1';
SET binlog_format=statement;
INSERT INTO t3 VALUES (31, foo(31,
'commit_before_prepare_ordered WAIT_FOR t2_waiting',
'commit_after_prepare_ordered SIGNAL t1_ready WAIT_FOR t1_cont'));
SET debug_sync='now WAIT_FOR master_queued1';
SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued2';
SET binlog_format=statement;
BEGIN;
INSERT INTO t3 VALUES (32, foo(32,
'ha_write_row_end SIGNAL t2_query WAIT_FOR t2_cont',
''));
INSERT INTO t3 VALUES (33, foo(33,
'group_commit_waiting_for_prior SIGNAL t2_waiting',
'group_commit_waiting_for_prior_killed SIGNAL t2_killed'));
COMMIT;
SET debug_sync='now WAIT_FOR master_queued2';
SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued3';
SET binlog_format=statement;
INSERT INTO t3 VALUES (34, foo(34,
'',
''));
SET debug_sync='now WAIT_FOR master_queued3';
SET debug_sync='now SIGNAL master_cont1';
SELECT * FROM t3 WHERE a >= 30 ORDER BY a;
a	b
31	31
32	32
33	33
34	34
SET sql_log_bin=0;
CALL mtr.add_suppression("Query execution was interrupted");
CALL mtr.add_suppression("Commit failed due to failure of an earlier commit on which this one depends");
CALL mtr.add_suppression("Slave: Connection was killed");
SET sql_log_bin=1;
SET debug_sync='now WAIT_FOR t2_query';
SET debug_sync='now SIGNAL t2_cont';
SET debug_sync='now WAIT_FOR t1_ready';
KILL THD_ID;
SET debug_sync='now WAIT_FOR t2_killed';
SET debug_sync='now SIGNAL t1_cont';
include/wait_for_slave_sql_error.inc [errno=1317,1963]
STOP SLAVE IO_THREAD;
SELECT * FROM t3 WHERE a >= 30 ORDER BY a;
a	b
31	31
SET GLOBAL slave_parallel_threads=0;
SET GLOBAL slave_parallel_threads=10;
SET sql_log_bin=0;
DROP FUNCTION foo;
CREATE FUNCTION foo(x INT, d1 VARCHAR(500), d2 VARCHAR(500))
RETURNS INT DETERMINISTIC
BEGIN
RETURN x;
END
||
SET sql_log_bin=1;
INSERT INTO t3 VALUES (39,0);
include/start_slave.inc
SELECT * FROM t3 WHERE a >= 30 ORDER BY a;
a	b
31	31
32	32
33	33
34	34
39	0
SET sql_log_bin=0;
DROP FUNCTION foo;
CREATE FUNCTION foo(x INT, d1 VARCHAR(500), d2 VARCHAR(500))
RETURNS INT DETERMINISTIC
BEGIN
IF d1 != '' THEN
SET debug_sync = d1;
END IF;
IF d2 != '' THEN
SET debug_sync = d2;
END IF;
RETURN x;
END
||
SET sql_log_bin=1;
include/stop_slave.inc
SET GLOBAL binlog_format=@old_format;
SET GLOBAL slave_parallel_threads=0;
SET GLOBAL slave_parallel_threads=10;
include/start_slave.inc
*** 2. Same as (1), but without restarting IO thread after kill of SQL threads ***
SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued1 WAIT_FOR master_cont1';
SET binlog_format=statement;
INSERT INTO t3 VALUES (41, foo(41,
'commit_before_prepare_ordered WAIT_FOR t2_waiting',
'commit_after_prepare_ordered SIGNAL t1_ready WAIT_FOR t1_cont'));
SET debug_sync='now WAIT_FOR master_queued1';
SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued2';
SET binlog_format=statement;
BEGIN;
INSERT INTO t3 VALUES (42, foo(42,
'ha_write_row_end SIGNAL t2_query WAIT_FOR t2_cont',
''));
INSERT INTO t3 VALUES (43, foo(43,
'group_commit_waiting_for_prior SIGNAL t2_waiting',
'group_commit_waiting_for_prior_killed SIGNAL t2_killed'));
COMMIT;
SET debug_sync='now WAIT_FOR master_queued2';
SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued3';
SET binlog_format=statement;
INSERT INTO t3 VALUES (44, foo(44,
'',
''));
SET debug_sync='now WAIT_FOR master_queued3';
SET debug_sync='now SIGNAL master_cont1';
SELECT * FROM t3 WHERE a >= 40 ORDER BY a;
a	b
41	41
42	42
43	43
44	44
SET debug_sync='now WAIT_FOR t2_query';
SET debug_sync='now SIGNAL t2_cont';
SET debug_sync='now WAIT_FOR t1_ready';
KILL THD_ID;
SET debug_sync='now WAIT_FOR t2_killed';
SET debug_sync='now SIGNAL t1_cont';
include/wait_for_slave_sql_error.inc [errno=1317,1963]
SELECT * FROM t3 WHERE a >= 40 ORDER BY a;
a	b
41	41
SET GLOBAL slave_parallel_threads=0;
SET GLOBAL slave_parallel_threads=10;
SET sql_log_bin=0;
DROP FUNCTION foo;
CREATE FUNCTION foo(x INT, d1 VARCHAR(500), d2 VARCHAR(500))
RETURNS INT DETERMINISTIC
BEGIN
RETURN x;
END
||
SET sql_log_bin=1;
INSERT INTO t3 VALUES (49,0);
START SLAVE SQL_THREAD;
SELECT * FROM t3 WHERE a >= 40 ORDER BY a;
a	b
41	41
42	42
43	43
44	44
49	0
SET sql_log_bin=0;
DROP FUNCTION foo;
CREATE FUNCTION foo(x INT, d1 VARCHAR(500), d2 VARCHAR(500))
RETURNS INT DETERMINISTIC
BEGIN
IF d1 != '' THEN
SET debug_sync = d1;
END IF;
IF d2 != '' THEN
SET debug_sync = d2;
END IF;
RETURN x;
END
||
SET sql_log_bin=1;
include/stop_slave.inc
SET GLOBAL binlog_format=@old_format;
SET GLOBAL slave_parallel_threads=0;
SET GLOBAL slave_parallel_threads=10;
include/start_slave.inc
*** 3. Same as (2), but not using gtid mode ***
include/stop_slave.inc
CHANGE MASTER TO master_use_gtid=no;
include/start_slave.inc
SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued1 WAIT_FOR master_cont1';
SET binlog_format=statement;
INSERT INTO t3 VALUES (51, foo(51,
'commit_before_prepare_ordered WAIT_FOR t2_waiting',
'commit_after_prepare_ordered SIGNAL t1_ready WAIT_FOR t1_cont'));
SET debug_sync='now WAIT_FOR master_queued1';
SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued2';
SET binlog_format=statement;
BEGIN;
INSERT INTO t3 VALUES (52, foo(52,
'ha_write_row_end SIGNAL t2_query WAIT_FOR t2_cont',
''));
INSERT INTO t3 VALUES (53, foo(53,
'group_commit_waiting_for_prior SIGNAL t2_waiting',
'group_commit_waiting_for_prior_killed SIGNAL t2_killed'));
COMMIT;
SET debug_sync='now WAIT_FOR master_queued2';
SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued3';
SET binlog_format=statement;
INSERT INTO t3 VALUES (54, foo(54,
'',
''));
SET debug_sync='now WAIT_FOR master_queued3';
SET debug_sync='now SIGNAL master_cont1';
SELECT * FROM t3 WHERE a >= 50 ORDER BY a;
a	b
51	51
52	52
53	53
54	54
SET debug_sync='now WAIT_FOR t2_query';
SET debug_sync='now SIGNAL t2_cont';
SET debug_sync='now WAIT_FOR t1_ready';
KILL THD_ID;
SET debug_sync='now WAIT_FOR t2_killed';
SET debug_sync='now SIGNAL t1_cont';
include/wait_for_slave_sql_error.inc [errno=1317,1963]
SELECT * FROM t3 WHERE a >= 50 ORDER BY a;
a	b
51	51
SET GLOBAL slave_parallel_threads=0;
SET GLOBAL slave_parallel_threads=10;
SET sql_log_bin=0;
DROP FUNCTION foo;
CREATE FUNCTION foo(x INT, d1 VARCHAR(500), d2 VARCHAR(500))
RETURNS INT DETERMINISTIC
BEGIN
RETURN x;
END
||
SET sql_log_bin=1;
INSERT INTO t3 VALUES (59,0);
START SLAVE SQL_THREAD;
SELECT * FROM t3 WHERE a >= 50 ORDER BY a;
a	b
51	51
52	52
53	53
54	54
59	0
SET sql_log_bin=0;
DROP FUNCTION foo;
CREATE FUNCTION foo(x INT, d1 VARCHAR(500), d2 VARCHAR(500))
RETURNS INT DETERMINISTIC
BEGIN
IF d1 != '' THEN
SET debug_sync = d1;
END IF;
IF d2 != '' THEN
SET debug_sync = d2;
END IF;
RETURN x;
END
||
SET sql_log_bin=1;
include/stop_slave.inc
CHANGE MASTER TO master_use_gtid=slave_pos;
include/start_slave.inc
include/stop_slave.inc
SET GLOBAL binlog_format=@old_format;
SET GLOBAL slave_parallel_threads=0;
SET GLOBAL slave_parallel_threads=3;
include/start_slave.inc
*** 4. Test killing thread that is waiting to start transaction until previous transaction commits ***
SET binlog_format=statement;
SET gtid_domain_id=2;
INSERT INTO t3 VALUES (60, foo(60,
'ha_write_row_end SIGNAL d2_query WAIT_FOR d2_cont2',
'rpl_parallel_end_of_group SIGNAL d2_done WAIT_FOR d2_cont'));
SET gtid_domain_id=0;
SET debug_sync='now WAIT_FOR d2_query';
SET gtid_domain_id=1;
BEGIN;
INSERT INTO t3 VALUES (61, foo(61,
'rpl_parallel_start_waiting_for_prior SIGNAL t3_waiting',
'rpl_parallel_start_waiting_for_prior_killed SIGNAL t3_killed'));
INSERT INTO t3 VALUES (62, foo(62,
'ha_write_row_end SIGNAL d1_query WAIT_FOR d1_cont2',
'rpl_parallel_end_of_group SIGNAL d1_done WAIT_FOR d1_cont'));
COMMIT;
SET gtid_domain_id=0;
SET debug_sync='now WAIT_FOR d1_query';
SET gtid_domain_id=0;
INSERT INTO t3 VALUES (63, foo(63,
'ha_write_row_end SIGNAL d0_query WAIT_FOR d0_cont2',
'rpl_parallel_end_of_group SIGNAL d0_done WAIT_FOR d0_cont'));
SET debug_sync='now WAIT_FOR d0_query';
SET debug_sync='now SIGNAL d2_cont2';
SET debug_sync='now WAIT_FOR d2_done';
SET debug_sync='now SIGNAL d1_cont2';
SET debug_sync='now WAIT_FOR d1_done';
SET debug_sync='now SIGNAL d0_cont2';
SET debug_sync='now WAIT_FOR d0_done';
SET binlog_format=statement;
INSERT INTO t3 VALUES (64, foo(64,
'commit_before_prepare_ordered SIGNAL t1_waiting WAIT_FOR t1_cont', ''));
SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued2 WAIT_FOR master_cont2';
INSERT INTO t3 VALUES (65, foo(65, '', ''));
SET debug_sync='now WAIT_FOR master_queued2';
SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued3';
INSERT INTO t3 VALUES (66, foo(66, '', ''));
SET debug_sync='now WAIT_FOR master_queued3';
SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued4';
INSERT INTO t3 VALUES (67, foo(67, '', ''));
SET debug_sync='now WAIT_FOR master_queued4';
SET debug_sync='now SIGNAL master_cont2';
SELECT * FROM t3 WHERE a >= 60 ORDER BY a;
a	b
60	60
61	61
62	62
63	63
64	64
65	65
66	66
67	67
SET debug_sync='now SIGNAL d0_cont';
SET debug_sync='now WAIT_FOR t1_waiting';
SET debug_sync='now SIGNAL d1_cont';
SET debug_sync='now WAIT_FOR t3_waiting';
SET debug_sync='now SIGNAL d2_cont';
KILL THD_ID;
SET debug_sync='now WAIT_FOR t3_killed';
SET debug_sync='now SIGNAL t1_cont';
include/wait_for_slave_sql_error.inc [errno=1317,1927,1963]
**** ERROR: timeout after 300 seconds while waiting for slave parameter Slave_SQL_Running = No ****

############################## server_2 ##############################

**** SHOW WARNINGS on server_2 ****
SHOW WARNINGS;
Level	Code	Message

**** SELECT replication-related variables on server_2 ****
SELECT NOW(), @@SERVER_ID;
NOW()	@@SERVER_ID
2014-03-11 13:03:36	2

**** SHOW SLAVE STATUS on server_2 ****
SHOW SLAVE STATUS;
Slave_IO_State	Waiting for master to send event
Master_Host	127.0.0.1
Master_User	root
Master_Port	16060
Connect_Retry	1
Master_Log_File	master-bin.000002
Read_Master_Log_Pos	7117
Relay_Log_File	slave-relay-bin.000002
Relay_Log_Pos	2015
Relay_Master_Log_File	master-bin.000002
Slave_IO_Running	Yes
Slave_SQL_Running	Yes
Replicate_Do_DB	
Replicate_Ignore_DB	
Replicate_Do_Table	
Replicate_Ignore_Table	
Replicate_Wild_Do_Table	
Replicate_Wild_Ignore_Table	
Last_Errno	1927
Last_Error	Connection was killed
Skip_Counter	0
Exec_Master_Log_Pos	6598
Relay_Log_Space	2534
Until_Condition	None
Until_Log_File	
Until_Log_Pos	0
Master_SSL_Allowed	No
Master_SSL_CA_File	
Master_SSL_CA_Path	
Master_SSL_Cert	
Master_SSL_Cipher	
Master_SSL_Key	
Seconds_Behind_Master	307
Master_SSL_Verify_Server_Cert	No
Last_IO_Errno	0
Last_IO_Error	
Last_SQL_Errno	1927
Last_SQL_Error	Connection was killed
Replicate_Ignore_Server_Ids	
Master_Server_Id	1
Master_SSL_Crl	
Master_SSL_Crlpath	
Using_Gtid	Slave_Pos
Gtid_IO_Pos	1-1-3,0-1-34,2-1-2

**** SHOW MASTER STATUS on server_2 ****
SHOW MASTER STATUS;
File	slave-bin.000003
Position	6689
Binlog_Do_DB	
Binlog_Ignore_DB	

**** SHOW SLAVE HOSTS on server_2 ****
SHOW SLAVE HOSTS;

**** SHOW PROCESSLIST on server_2 ****
SHOW PROCESSLIST;
Id	User	Host	db	Command	Time	State	Info	Progress
4	root	localhost:53835	test	Query	0	init	SHOW PROCESSLIST	0.000
5	root	localhost:53836	test	Sleep	310		NULL	0.000
20	root	localhost:53846	test	Sleep	309		NULL	0.000
46	root	localhost:53852	test	Sleep	309		NULL	0.000
126	system user		NULL	Connect	307	Waiting for work from SQL thread	NULL	0.000
127	system user		NULL	Connect	307	Waiting for work from SQL thread	NULL	0.000
129	system user		NULL	Connect	308	Waiting for master to send event	NULL	0.000
130	system user		NULL	Connect	308	Reading event from the relay log	NULL	0.000

**** SHOW BINARY LOGS on server_2 ****
SHOW BINARY LOGS;
Log_name	File_size
slave-bin.000001	2045
slave-bin.000002	987
slave-bin.000003	6689

**** SHOW BINLOG EVENTS on server_2 ****
binlog_name = 'slave-bin.000003'
SHOW BINLOG EVENTS IN 'slave-bin.000003';
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
slave-bin.000003	4	Format_desc	2	248	Server ver: 10.1.0-MariaDB-debug-log, Binlog ver: 4
slave-bin.000003	248	Gtid_list	2	319	[1-1-2,2-1-1,0-1-9]
slave-bin.000003	319	Binlog_checkpoint	2	358	slave-bin.000002
slave-bin.000003	358	Binlog_checkpoint	2	397	slave-bin.000003
slave-bin.000003	397	Gtid	1	435	GTID 0-1-10
slave-bin.000003	435	Query	1	554	use `test`; CREATE TABLE t3 (a INT PRIMARY KEY, b INT) ENGINE=InnoDB
slave-bin.000003	554	Gtid	1	592	BEGIN GTID 0-1-11
slave-bin.000003	592	Query	1	703	use `test`; INSERT INTO t3 VALUES (1,1), (3,3), (5,5), (7,7)
slave-bin.000003	703	Xid	1	730	COMMIT /* xid=714 */
slave-bin.000003	730	Gtid	1	770	BEGIN GTID 0-1-12 cid=720
slave-bin.000003	770	Query	1	958	use `test`; INSERT INTO t3 VALUES (2, foo(12,
'commit_after_release_LOCK_prepare_ordered SIGNAL slave_queued1 WAIT_FOR slave_cont1',
''))
slave-bin.000003	958	Xid	1	985	COMMIT /* xid=720 */
slave-bin.000003	985	Gtid	1	1025	BEGIN GTID 0-1-13 cid=720
slave-bin.000003	1025	Query	1	1192	use `test`; INSERT INTO t3 VALUES (4, foo(14,
'commit_after_release_LOCK_prepare_ordered SIGNAL slave_queued2',
''))
slave-bin.000003	1192	Xid	1	1219	COMMIT /* xid=722 */
slave-bin.000003	1219	Gtid	1	1259	BEGIN GTID 0-1-14 cid=720
slave-bin.000003	1259	Query	1	1415	use `test`; INSERT INTO t3 VALUES (6, foo(16,
'group_commit_waiting_for_prior SIGNAL slave_queued3',
''))
slave-bin.000003	1415	Xid	1	1442	COMMIT /* xid=728 */
slave-bin.000003	1442	Gtid	1	1480	BEGIN GTID 0-1-15
slave-bin.000003	1480	Query	1	1569	use `test`; INSERT INTO t1 VALUES (20)
slave-bin.000003	1569	Query	1	1638	COMMIT
slave-bin.000003	1638	Gtid	1	1676	BEGIN GTID 0-1-16
slave-bin.000003	1676	Query	1	1765	use `test`; INSERT INTO t2 VALUES (20)
slave-bin.000003	1765	Query	1	1854	use `test`; INSERT INTO t2 VALUES (21)
slave-bin.000003	1854	Query	1	1947	use `test`; INSERT INTO t3 VALUES (20, 20)
slave-bin.000003	1947	Xid	1	1974	COMMIT /* xid=873 */
slave-bin.000003	1974	Gtid	1	2012	BEGIN GTID 0-1-16
slave-bin.000003	2012	Query	1	2104	use `test`; INSERT INTO t3 VALUES(21, 21)
slave-bin.000003	2104	Xid	1	2131	COMMIT /* xid=947 */
slave-bin.000003	2131	Gtid	1	2169	BEGIN GTID 0-1-17
slave-bin.000003	2169	Query	1	2261	use `test`; INSERT INTO t3 VALUES(22, 22)
slave-bin.000003	2261	Xid	1	2288	COMMIT /* xid=951 */
slave-bin.000003	2288	Gtid	1	2326	BEGIN GTID 0-1-18
slave-bin.000003	2326	Query	1	2542	use `test`; INSERT INTO t3 VALUES (31, foo(31,
'commit_before_prepare_ordered WAIT_FOR t2_waiting',
'commit_after_prepare_ordered SIGNAL t1_ready WAIT_FOR t1_cont'))
slave-bin.000003	2542	Xid	1	2569	COMMIT /* xid=1185 */
slave-bin.000003	2569	Gtid	1	2607	BEGIN GTID 0-1-19
slave-bin.000003	2607	Query	1	2762	use `test`; INSERT INTO t3 VALUES (32, foo(32,
'ha_write_row_end SIGNAL t2_query WAIT_FOR t2_cont',
''))
slave-bin.000003	2762	Query	1	2970	use `test`; INSERT INTO t3 VALUES (33, foo(33,
'group_commit_waiting_for_prior SIGNAL t2_waiting',
'group_commit_waiting_for_prior_killed SIGNAL t2_killed'))
slave-bin.000003	2970	Xid	1	2997	COMMIT /* xid=1259 */
slave-bin.000003	2997	Gtid	1	3035	BEGIN GTID 0-1-20
slave-bin.000003	3035	Query	1	3141	use `test`; INSERT INTO t3 VALUES (34, foo(34,
'',
''))
slave-bin.000003	3141	Xid	1	3168	COMMIT /* xid=1261 */
slave-bin.000003	3168	Gtid	1	3206	BEGIN GTID 0-1-21
slave-bin.000003	3206	Query	1	3297	use `test`; INSERT INTO t3 VALUES (39,0)
slave-bin.000003	3297	Xid	1	3324	COMMIT /* xid=1267 */
slave-bin.000003	3324	Gtid	1	3362	BEGIN GTID 0-1-22
slave-bin.000003	3362	Query	1	3578	use `test`; INSERT INTO t3 VALUES (41, foo(41,
'commit_before_prepare_ordered WAIT_FOR t2_waiting',
'commit_after_prepare_ordered SIGNAL t1_ready WAIT_FOR t1_cont'))
slave-bin.000003	3578	Xid	1	3605	COMMIT /* xid=1495 */
slave-bin.000003	3605	Gtid	1	3645	BEGIN GTID 0-1-23 cid=1567
slave-bin.000003	3645	Query	1	3800	use `test`; INSERT INTO t3 VALUES (42, foo(42,
'ha_write_row_end SIGNAL t2_query WAIT_FOR t2_cont',
''))
slave-bin.000003	3800	Query	1	4008	use `test`; INSERT INTO t3 VALUES (43, foo(43,
'group_commit_waiting_for_prior SIGNAL t2_waiting',
'group_commit_waiting_for_prior_killed SIGNAL t2_killed'))
slave-bin.000003	4008	Xid	1	4035	COMMIT /* xid=1562 */
slave-bin.000003	4035	Gtid	1	4075	BEGIN GTID 0-1-24 cid=1567
slave-bin.000003	4075	Query	1	4181	use `test`; INSERT INTO t3 VALUES (44, foo(44,
'',
''))
slave-bin.000003	4181	Xid	1	4208	COMMIT /* xid=1564 */
slave-bin.000003	4208	Gtid	1	4246	BEGIN GTID 0-1-25
slave-bin.000003	4246	Query	1	4337	use `test`; INSERT INTO t3 VALUES (49,0)
slave-bin.000003	4337	Xid	1	4364	COMMIT /* xid=1570 */
slave-bin.000003	4364	Gtid	1	4402	BEGIN GTID 0-1-26
slave-bin.000003	4402	Query	1	4618	use `test`; INSERT INTO t3 VALUES (51, foo(51,
'commit_before_prepare_ordered WAIT_FOR t2_waiting',
'commit_after_prepare_ordered SIGNAL t1_ready WAIT_FOR t1_cont'))
slave-bin.000003	4618	Xid	1	4645	COMMIT /* xid=1873 */
slave-bin.000003	4645	Gtid	1	4683	BEGIN GTID 0-1-27
slave-bin.000003	4683	Query	1	4838	use `test`; INSERT INTO t3 VALUES (52, foo(52,
'ha_write_row_end SIGNAL t2_query WAIT_FOR t2_cont',
''))
slave-bin.000003	4838	Query	1	5046	use `test`; INSERT INTO t3 VALUES (53, foo(53,
'group_commit_waiting_for_prior SIGNAL t2_waiting',
'group_commit_waiting_for_prior_killed SIGNAL t2_killed'))
slave-bin.000003	5046	Xid	1	5073	COMMIT /* xid=1939 */
slave-bin.000003	5073	Gtid	1	5111	BEGIN GTID 0-1-28
slave-bin.000003	5111	Query	1	5217	use `test`; INSERT INTO t3 VALUES (54, foo(54,
'',
''))
slave-bin.000003	5217	Xid	1	5244	COMMIT /* xid=1942 */
slave-bin.000003	5244	Gtid	1	5282	BEGIN GTID 0-1-29
slave-bin.000003	5282	Query	1	5373	use `test`; INSERT INTO t3 VALUES (59,0)
slave-bin.000003	5373	Xid	1	5400	COMMIT /* xid=1948 */
slave-bin.000003	5400	Gtid	1	5438	BEGIN GTID 2-1-2
slave-bin.000003	5438	Query	1	5651	use `test`; INSERT INTO t3 VALUES (60, foo(60,
'ha_write_row_end SIGNAL d2_query WAIT_FOR d2_cont2',
'rpl_parallel_end_of_group SIGNAL d2_done WAIT_FOR d2_cont'))
slave-bin.000003	5651	Xid	1	5678	COMMIT /* xid=2251 */
slave-bin.000003	5678	Gtid	1	5716	BEGIN GTID 1-1-3
slave-bin.000003	5716	Query	1	5936	use `test`; INSERT INTO t3 VALUES (61, foo(61,
'rpl_parallel_start_waiting_for_prior SIGNAL t3_waiting',
'rpl_parallel_start_waiting_for_prior_killed SIGNAL t3_killed'))
slave-bin.000003	5936	Query	1	6149	use `test`; INSERT INTO t3 VALUES (62, foo(62,
'ha_write_row_end SIGNAL d1_query WAIT_FOR d1_cont2',
'rpl_parallel_end_of_group SIGNAL d1_done WAIT_FOR d1_cont'))
slave-bin.000003	6149	Xid	1	6176	COMMIT /* xid=2261 */
slave-bin.000003	6176	Gtid	1	6214	BEGIN GTID 0-1-30
slave-bin.000003	6214	Query	1	6427	use `test`; INSERT INTO t3 VALUES (63, foo(63,
'ha_write_row_end SIGNAL d0_query WAIT_FOR d0_cont2',
'rpl_parallel_end_of_group SIGNAL d0_done WAIT_FOR d0_cont'))
slave-bin.000003	6427	Xid	1	6454	COMMIT /* xid=2275 */
slave-bin.000003	6454	Gtid	1	6492	BEGIN GTID 0-1-31
slave-bin.000003	6492	Query	1	6662	use `test`; INSERT INTO t3 VALUES (64, foo(64,
'commit_before_prepare_ordered SIGNAL t1_waiting WAIT_FOR t1_cont', ''))
slave-bin.000003	6662	Xid	1	6689	COMMIT /* xid=2291 */

**** SHOW RELAYLOG EVENTS on server_2 ****
relaylog_name = 'slave-relay-bin.000002'
SHOW RELAYLOG EVENTS IN 'slave-relay-bin.000002';
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
slave-relay-bin.000002	4	Format_desc	2	248	Server ver: 10.1.0-MariaDB-debug-log, Binlog ver: 4
slave-relay-bin.000002	248	Rotate	1	0	master-bin.000002;pos=4
slave-relay-bin.000002	292	Format_desc	1	248	Server ver: 10.1.0-MariaDB-debug-log, Binlog ver: 4
slave-relay-bin.000002	536	Gtid_list	1	319	[1-1-2,2-1-1,0-1-9]
slave-relay-bin.000002	607	Binlog_checkpoint	1	359	master-bin.000001
slave-relay-bin.000002	647	Binlog_checkpoint	1	399	master-bin.000002
slave-relay-bin.000002	687	Gtid_list	1	5309	[0-1-29]
slave-relay-bin.000002	726	Gtid	1	5347	BEGIN GTID 2-1-2
slave-relay-bin.000002	764	Query	1	5560	use `test`; INSERT INTO t3 VALUES (60, foo(60,
'ha_write_row_end SIGNAL d2_query WAIT_FOR d2_cont2',
'rpl_parallel_end_of_group SIGNAL d2_done WAIT_FOR d2_cont'))
slave-relay-bin.000002	977	Xid	1	5587	COMMIT /* xid=423 */
slave-relay-bin.000002	1004	Gtid	1	5625	BEGIN GTID 1-1-3
slave-relay-bin.000002	1042	Query	1	5845	use `test`; INSERT INTO t3 VALUES (61, foo(61,
'rpl_parallel_start_waiting_for_prior SIGNAL t3_waiting',
'rpl_parallel_start_waiting_for_prior_killed SIGNAL t3_killed'))
slave-relay-bin.000002	1262	Query	1	6058	use `test`; INSERT INTO t3 VALUES (62, foo(62,
'ha_write_row_end SIGNAL d1_query WAIT_FOR d1_cont2',
'rpl_parallel_end_of_group SIGNAL d1_done WAIT_FOR d1_cont'))
slave-relay-bin.000002	1475	Xid	1	6085	COMMIT /* xid=428 */
slave-relay-bin.000002	1502	Gtid	1	6123	BEGIN GTID 0-1-30
slave-relay-bin.000002	1540	Query	1	6336	use `test`; INSERT INTO t3 VALUES (63, foo(63,
'ha_write_row_end SIGNAL d0_query WAIT_FOR d0_cont2',
'rpl_parallel_end_of_group SIGNAL d0_done WAIT_FOR d0_cont'))
slave-relay-bin.000002	1753	Xid	1	6363	COMMIT /* xid=435 */
slave-relay-bin.000002	1780	Gtid	1	6401	BEGIN GTID 0-1-31
slave-relay-bin.000002	1818	Query	1	6571	use `test`; INSERT INTO t3 VALUES (64, foo(64,
'commit_before_prepare_ordered SIGNAL t1_waiting WAIT_FOR t1_cont', ''))
slave-relay-bin.000002	1988	Xid	1	6598	COMMIT /* xid=438 */
slave-relay-bin.000002	2015	Gtid	1	6638	BEGIN GTID 0-1-32 cid=441
slave-relay-bin.000002	2055	Query	1	6744	use `test`; INSERT INTO t3 VALUES (65, foo(65, '', ''))
slave-relay-bin.000002	2161	Xid	1	6771	COMMIT /* xid=441 */
slave-relay-bin.000002	2188	Gtid	1	6811	BEGIN GTID 0-1-33 cid=441
slave-relay-bin.000002	2228	Query	1	6917	use `test`; INSERT INTO t3 VALUES (66, foo(66, '', ''))
slave-relay-bin.000002	2334	Xid	1	6944	COMMIT /* xid=445 */
slave-relay-bin.000002	2361	Gtid	1	6984	BEGIN GTID 0-1-34 cid=441
slave-relay-bin.000002	2401	Query	1	7090	use `test`; INSERT INTO t3 VALUES (67, foo(67, '', ''))
slave-relay-bin.000002	2507	Xid	1	7117	COMMIT /* xid=449 */

############################## server_1 ##############################

**** SHOW WARNINGS on server_1 ****
SHOW WARNINGS;
Level	Code	Message

**** SELECT replication-related variables on server_1 ****
SELECT NOW(), @@SERVER_ID;
NOW()	@@SERVER_ID
2014-03-11 13:03:36	1

**** SHOW SLAVE STATUS on server_1 ****
SHOW SLAVE STATUS;

**** SHOW MASTER STATUS on server_1 ****
SHOW MASTER STATUS;
File	master-bin.000002
Position	7117
Binlog_Do_DB	
Binlog_Ignore_DB	

**** SHOW SLAVE HOSTS on server_1 ****
SHOW SLAVE HOSTS;
Server_id	2
Host	127.0.0.1
Port	16061
Master_id	1

**** SHOW PROCESSLIST on server_1 ****
SHOW PROCESSLIST;
Id	User	Host	db	Command	Time	State	Info	Progress
4	root	localhost	test	Sleep	310		NULL	0.000
5	root	localhost:44014	test	Query	0	init	SHOW PROCESSLIST	0.000
6	root	localhost:44015	test	Sleep	310		NULL	0.000
11	root	localhost:44030	test	Sleep	307		NULL	0.000
12	root	localhost:44032	test	Sleep	307		NULL	0.000
13	root	localhost:44033	test	Sleep	307		NULL	0.000
23	root	localhost:44085	NULL	Binlog Dump	308	Master has sent all binlog to slave; waiting for binlog to be updated	NULL	0.000

**** SHOW BINARY LOGS on server_1 ****
SHOW BINARY LOGS;
Log_name	File_size
master-bin.000001	2606
master-bin.000002	7117

**** SHOW BINLOG EVENTS on server_1 ****
binlog_name = 'master-bin.000002'
SHOW BINLOG EVENTS IN 'master-bin.000002';
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000002	4	Format_desc	1	248	Server ver: 10.1.0-MariaDB-debug-log, Binlog ver: 4
master-bin.000002	248	Gtid_list	1	319	[1-1-2,2-1-1,0-1-9]
master-bin.000002	319	Binlog_checkpoint	1	359	master-bin.000001
master-bin.000002	359	Binlog_checkpoint	1	399	master-bin.000002
master-bin.000002	399	Gtid	1	437	GTID 0-1-10
master-bin.000002	437	Query	1	556	use `test`; CREATE TABLE t3 (a INT PRIMARY KEY, b INT) ENGINE=InnoDB
master-bin.000002	556	Gtid	1	594	BEGIN GTID 0-1-11
master-bin.000002	594	Query	1	705	use `test`; INSERT INTO t3 VALUES (1,1), (3,3), (5,5), (7,7)
master-bin.000002	705	Xid	1	732	COMMIT /* xid=169 */
master-bin.000002	732	Gtid	1	772	BEGIN GTID 0-1-12 cid=173
master-bin.000002	772	Query	1	960	use `test`; INSERT INTO t3 VALUES (2, foo(12,
'commit_after_release_LOCK_prepare_ordered SIGNAL slave_queued1 WAIT_FOR slave_cont1',
''))
master-bin.000002	960	Xid	1	987	COMMIT /* xid=173 */
master-bin.000002	987	Gtid	1	1027	BEGIN GTID 0-1-13 cid=173
master-bin.000002	1027	Query	1	1194	use `test`; INSERT INTO t3 VALUES (4, foo(14,
'commit_after_release_LOCK_prepare_ordered SIGNAL slave_queued2',
''))
master-bin.000002	1194	Xid	1	1221	COMMIT /* xid=178 */
master-bin.000002	1221	Gtid	1	1261	BEGIN GTID 0-1-14 cid=173
master-bin.000002	1261	Query	1	1417	use `test`; INSERT INTO t3 VALUES (6, foo(16,
'group_commit_waiting_for_prior SIGNAL slave_queued3',
''))
master-bin.000002	1417	Xid	1	1444	COMMIT /* xid=183 */
master-bin.000002	1444	Gtid	1	1482	BEGIN GTID 0-1-15
master-bin.000002	1482	Query	1	1571	use `test`; INSERT INTO t2 VALUES (20)
master-bin.000002	1571	Query	1	1660	use `test`; INSERT INTO t1 VALUES (20)
master-bin.000002	1660	Query	1	1749	use `test`; INSERT INTO t2 VALUES (21)
master-bin.000002	1749	Query	1	1842	use `test`; INSERT INTO t3 VALUES (20, 20)
master-bin.000002	1842	Xid	1	1869	COMMIT /* xid=246 */
master-bin.000002	1869	Gtid	1	1907	BEGIN GTID 0-1-16
master-bin.000002	1907	Query	1	1999	use `test`; INSERT INTO t3 VALUES(21, 21)
master-bin.000002	1999	Xid	1	2026	COMMIT /* xid=251 */
master-bin.000002	2026	Gtid	1	2064	BEGIN GTID 0-1-17
master-bin.000002	2064	Query	1	2156	use `test`; INSERT INTO t3 VALUES(22, 22)
master-bin.000002	2156	Xid	1	2183	COMMIT /* xid=252 */
master-bin.000002	2183	Gtid	1	2223	BEGIN GTID 0-1-18 cid=290
master-bin.000002	2223	Query	1	2439	use `test`; INSERT INTO t3 VALUES (31, foo(31,
'commit_before_prepare_ordered WAIT_FOR t2_waiting',
'commit_after_prepare_ordered SIGNAL t1_ready WAIT_FOR t1_cont'))
master-bin.000002	2439	Xid	1	2466	COMMIT /* xid=290 */
master-bin.000002	2466	Gtid	1	2506	BEGIN GTID 0-1-19 cid=290
master-bin.000002	2506	Query	1	2661	use `test`; INSERT INTO t3 VALUES (32, foo(32,
'ha_write_row_end SIGNAL t2_query WAIT_FOR t2_cont',
''))
master-bin.000002	2661	Query	1	2869	use `test`; INSERT INTO t3 VALUES (33, foo(33,
'group_commit_waiting_for_prior SIGNAL t2_waiting',
'group_commit_waiting_for_prior_killed SIGNAL t2_killed'))
master-bin.000002	2869	Xid	1	2896	COMMIT /* xid=296 */
master-bin.000002	2896	Gtid	1	2936	BEGIN GTID 0-1-20 cid=290
master-bin.000002	2936	Query	1	3042	use `test`; INSERT INTO t3 VALUES (34, foo(34,
'',
''))
master-bin.000002	3042	Xid	1	3069	COMMIT /* xid=304 */
master-bin.000002	3069	Gtid	1	3107	BEGIN GTID 0-1-21
master-bin.000002	3107	Query	1	3198	use `test`; INSERT INTO t3 VALUES (39,0)
master-bin.000002	3198	Xid	1	3225	COMMIT /* xid=309 */
master-bin.000002	3225	Gtid	1	3265	BEGIN GTID 0-1-22 cid=335
master-bin.000002	3265	Query	1	3481	use `test`; INSERT INTO t3 VALUES (41, foo(41,
'commit_before_prepare_ordered WAIT_FOR t2_waiting',
'commit_after_prepare_ordered SIGNAL t1_ready WAIT_FOR t1_cont'))
master-bin.000002	3481	Xid	1	3508	COMMIT /* xid=335 */
master-bin.000002	3508	Gtid	1	3548	BEGIN GTID 0-1-23 cid=335
master-bin.000002	3548	Query	1	3703	use `test`; INSERT INTO t3 VALUES (42, foo(42,
'ha_write_row_end SIGNAL t2_query WAIT_FOR t2_cont',
''))
master-bin.000002	3703	Query	1	3911	use `test`; INSERT INTO t3 VALUES (43, foo(43,
'group_commit_waiting_for_prior SIGNAL t2_waiting',
'group_commit_waiting_for_prior_killed SIGNAL t2_killed'))
master-bin.000002	3911	Xid	1	3938	COMMIT /* xid=341 */
master-bin.000002	3938	Gtid	1	3978	BEGIN GTID 0-1-24 cid=335
master-bin.000002	3978	Query	1	4084	use `test`; INSERT INTO t3 VALUES (44, foo(44,
'',
''))
master-bin.000002	4084	Xid	1	4111	COMMIT /* xid=349 */
master-bin.000002	4111	Gtid	1	4149	BEGIN GTID 0-1-25
master-bin.000002	4149	Query	1	4240	use `test`; INSERT INTO t3 VALUES (49,0)
master-bin.000002	4240	Xid	1	4267	COMMIT /* xid=354 */
master-bin.000002	4267	Gtid	1	4307	BEGIN GTID 0-1-26 cid=378
master-bin.000002	4307	Query	1	4523	use `test`; INSERT INTO t3 VALUES (51, foo(51,
'commit_before_prepare_ordered WAIT_FOR t2_waiting',
'commit_after_prepare_ordered SIGNAL t1_ready WAIT_FOR t1_cont'))
master-bin.000002	4523	Xid	1	4550	COMMIT /* xid=378 */
master-bin.000002	4550	Gtid	1	4590	BEGIN GTID 0-1-27 cid=378
master-bin.000002	4590	Query	1	4745	use `test`; INSERT INTO t3 VALUES (52, foo(52,
'ha_write_row_end SIGNAL t2_query WAIT_FOR t2_cont',
''))
master-bin.000002	4745	Query	1	4953	use `test`; INSERT INTO t3 VALUES (53, foo(53,
'group_commit_waiting_for_prior SIGNAL t2_waiting',
'group_commit_waiting_for_prior_killed SIGNAL t2_killed'))
master-bin.000002	4953	Xid	1	4980	COMMIT /* xid=384 */
master-bin.000002	4980	Gtid	1	5020	BEGIN GTID 0-1-28 cid=378
master-bin.000002	5020	Query	1	5126	use `test`; INSERT INTO t3 VALUES (54, foo(54,
'',
''))
master-bin.000002	5126	Xid	1	5153	COMMIT /* xid=392 */
master-bin.000002	5153	Gtid	1	5191	BEGIN GTID 0-1-29
master-bin.000002	5191	Query	1	5282	use `test`; INSERT INTO t3 VALUES (59,0)
master-bin.000002	5282	Xid	1	5309	COMMIT /* xid=397 */
master-bin.000002	5309	Gtid	1	5347	BEGIN GTID 2-1-2
master-bin.000002	5347	Query	1	5560	use `test`; INSERT INTO t3 VALUES (60, foo(60,
'ha_write_row_end SIGNAL d2_query WAIT_FOR d2_cont2',
'rpl_parallel_end_of_group SIGNAL d2_done WAIT_FOR d2_cont'))
master-bin.000002	5560	Xid	1	5587	COMMIT /* xid=423 */
master-bin.000002	5587	Gtid	1	5625	BEGIN GTID 1-1-3
master-bin.000002	5625	Query	1	5845	use `test`; INSERT INTO t3 VALUES (61, foo(61,
'rpl_parallel_start_waiting_for_prior SIGNAL t3_waiting',
'rpl_parallel_start_waiting_for_prior_killed SIGNAL t3_killed'))
master-bin.000002	5845	Query	1	6058	use `test`; INSERT INTO t3 VALUES (62, foo(62,
'ha_write_row_end SIGNAL d1_query WAIT_FOR d1_cont2',
'rpl_parallel_end_of_group SIGNAL d1_done WAIT_FOR d1_cont'))
master-bin.000002	6058	Xid	1	6085	COMMIT /* xid=428 */
master-bin.000002	6085	Gtid	1	6123	BEGIN GTID 0-1-30
master-bin.000002	6123	Query	1	6336	use `test`; INSERT INTO t3 VALUES (63, foo(63,
'ha_write_row_end SIGNAL d0_query WAIT_FOR d0_cont2',
'rpl_parallel_end_of_group SIGNAL d0_done WAIT_FOR d0_cont'))
master-bin.000002	6336	Xid	1	6363	COMMIT /* xid=435 */
master-bin.000002	6363	Gtid	1	6401	BEGIN GTID 0-1-31
master-bin.000002	6401	Query	1	6571	use `test`; INSERT INTO t3 VALUES (64, foo(64,
'commit_before_prepare_ordered SIGNAL t1_waiting WAIT_FOR t1_cont', ''))
master-bin.000002	6571	Xid	1	6598	COMMIT /* xid=438 */
master-bin.000002	6598	Gtid	1	6638	BEGIN GTID 0-1-32 cid=441
master-bin.000002	6638	Query	1	6744	use `test`; INSERT INTO t3 VALUES (65, foo(65, '', ''))
master-bin.000002	6744	Xid	1	6771	COMMIT /* xid=441 */
master-bin.000002	6771	Gtid	1	6811	BEGIN GTID 0-1-33 cid=441
master-bin.000002	6811	Query	1	6917	use `test`; INSERT INTO t3 VALUES (66, foo(66, '', ''))
master-bin.000002	6917	Xid	1	6944	COMMIT /* xid=445 */
master-bin.000002	6944	Gtid	1	6984	BEGIN GTID 0-1-34 cid=441
master-bin.000002	6984	Query	1	7090	use `test`; INSERT INTO t3 VALUES (67, foo(67, '', ''))
master-bin.000002	7090	Xid	1	7117	COMMIT /* xid=449 */

**** SHOW RELAYLOG EVENTS on server_1 ****
relaylog_name = 'No such row'
SHOW RELAYLOG EVENTS IN 'No such row';
Log_name	Pos	Event_type	Server_id	End_log_pos	Info