1--source include/have_innodb.inc 2--source include/have_debug.inc 3--source include/have_debug_sync.inc 4--source include/master-slave.inc 5 6--connection server_2 7SET @old_parallel_threads=@@GLOBAL.slave_parallel_threads; 8--source include/stop_slave.inc 9SET GLOBAL slave_parallel_threads=10; 10CHANGE MASTER TO master_use_gtid=current_pos; 11--source include/start_slave.inc 12 13 14--echo *** MDEV-6589: Incorrect relay log start position when restarting SQL thread after error in parallel replication *** 15 16--connection server_1 17ALTER TABLE mysql.gtid_slave_pos ENGINE=InnoDB; 18CREATE TABLE t1 (a int PRIMARY KEY) ENGINE=MyISAM; 19CREATE TABLE t2 (a int PRIMARY KEY) ENGINE=InnoDB; 20INSERT INTO t1 VALUES (1); 21INSERT INTO t2 VALUES (1); 22--save_master_pos 23 24--connection server_2 25--sync_with_master 26SELECT * FROM t1; 27SELECT * FROM t2; 28 29# Block one domain, which we will later cause to give an error. And let some 30# other domains proceed so we can check that after restart, the slave is able 31# to correctly restart each domain in a separate position. 32 33--connect (con_temp1,127.0.0.1,root,,test,$SERVER_MYPORT_2,) 34SET sql_log_bin=0; 35BEGIN; 36INSERT INTO t2 VALUES (5); 37 38--connection server_1 39SET gtid_domain_id=0; 40INSERT INTO t1 VALUES (2); 41INSERT INTO t2 VALUES (3); 42FLUSH LOGS; 43INSERT INTO t1 VALUES (4); 44 45SET gtid_domain_id=1; 46# This query will be blocked on the slave, and later give a duplicate key error. 47INSERT INTO t2 VALUES (5); 48 49SET gtid_domain_id=0; 50INSERT INTO t1 VALUES (6); 51INSERT INTO t1 VALUES (7); 52 53SET gtid_domain_id=2; 54INSERT INTO t2 VALUES (8); 55INSERT INTO t1 VALUES (9); 56FLUSH LOGS; 57 58SET gtid_domain_id=3; 59INSERT INTO t2 VALUES (10); 60INSERT INTO t1 VALUES (11); 61 62# These cannot be replicated before the error, as a prior commit is blocked. 63SET gtid_domain_id=1; 64INSERT INTO t1 VALUES (12); 65INSERT INTO t2 VALUES (13); 66 67SET gtid_domain_id=0; 68INSERT INTO t2 VALUES (14); 69FLUSH LOGS; 70 71SET gtid_domain_id=3; 72INSERT INTO t2 VALUES (15); 73 74SET gtid_domain_id=2; 75INSERT INTO t2 VALUES (16); 76 77SET gtid_domain_id=0; 78INSERT INTO t1 VALUES (17); 79SET @gtid0 = @@last_gtid; 80SET gtid_domain_id=2; 81INSERT INTO t1 VALUES (18); 82SET @gtid2 = @@last_gtid; 83SET gtid_domain_id=3; 84INSERT INTO t1 VALUES (19); 85SET @gtid3 = @@last_gtid; 86--let $wait_pos= `SELECT CONCAT(@gtid0, ",", @gtid2, ",", @gtid3)` 87 88SELECT * FROM t1 ORDER BY a; 89SELECT * FROM t2 ORDER BY a; 90--source include/save_master_gtid.inc 91 92 93--connection server_2 94# First wait for domains 0, 2, and 3 to complete. 95--replace_result $wait_pos WAIT_POS 96eval SELECT MASTER_GTID_WAIT('$wait_pos'); 97 98# Then release the row lock, and wait for the domain 1 to fail with 99# duplicate key error. 100--connection con_temp1 101COMMIT; 102SET sql_log_bin=1; 103 104--connection server_2 105--let $slave_sql_errno= 1062 106--source include/wait_for_slave_sql_error.inc 107 108SELECT * FROM t1 ORDER BY a; 109SELECT * FROM t2 ORDER BY a; 110 111SET sql_log_bin=0; 112DELETE FROM t2 WHERE a=5; 113SET sql_log_bin=1; 114--source include/start_slave.inc 115--source include/sync_with_master_gtid.inc 116 117SELECT * FROM t1 ORDER BY a; 118SELECT * FROM t2 ORDER BY a; 119 120 121# Clean up. 122--connection server_2 123--source include/stop_slave.inc 124SET GLOBAL slave_parallel_threads=@old_parallel_threads; 125--source include/start_slave.inc 126SET DEBUG_SYNC= 'RESET'; 127 128--connection server_1 129DROP TABLE t1,t2; 130SET DEBUG_SYNC= 'RESET'; 131 132--source include/rpl_end.inc 133