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