mirror of
https://github.com/MariaDB/server.git
synced 2025-07-29 05:21:33 +03:00
Split rpl_parallel into two tests to make it easier
to know what goes wrong. rpl_parallel_conflicts now contains the tests that can cause row conflicts in replication.
This commit is contained in:
Monty
312
mysql-test/suite/rpl/r/parallel_conflicts.result
Normal file
312
mysql-test/suite/rpl/r/parallel_conflicts.result
Normal file
@ -0,0 +1,312 @@
|
|||||||
|
include/master-slave.inc
|
||||||
|
[connection master]
|
||||||
|
connection server_2;
|
||||||
|
SET @old_parallel_threads=@@GLOBAL.slave_parallel_threads;
|
||||||
|
include/stop_slave.inc
|
||||||
|
SET GLOBAL slave_parallel_threads=10;
|
||||||
|
SET GLOBAL slave_parallel_mode='conservative';
|
||||||
|
include/start_slave.inc
|
||||||
|
*** MDEV-7847: "Slave worker thread retried transaction 10 time(s) in vain, giving up", followed by replication hanging ***
|
||||||
|
*** MDEV-7882: Excessive transaction retry in parallel replication ***
|
||||||
|
connection server_1;
|
||||||
|
CREATE TABLE t7 (a int PRIMARY KEY, b INT) ENGINE=InnoDB;
|
||||||
|
CREATE TABLE t8 (a int PRIMARY KEY, b INT) ENGINE=InnoDB;
|
||||||
|
connection server_2;
|
||||||
|
include/stop_slave.inc
|
||||||
|
SET GLOBAL slave_parallel_threads=40;
|
||||||
|
SELECT @old_retries:=@@GLOBAL.slave_transaction_retries;
|
||||||
|
@old_retries:=@@GLOBAL.slave_transaction_retries
|
||||||
|
10
|
||||||
|
SET GLOBAL slave_transaction_retries= 5;
|
||||||
|
connection server_1;
|
||||||
|
INSERT INTO t7 VALUES (1,1), (2,2), (3,3), (4,4), (5,5);
|
||||||
|
SET @old_dbug= @@SESSION.debug_dbug;
|
||||||
|
SET @commit_id= 42;
|
||||||
|
SET SESSION debug_dbug="+d,binlog_force_commit_id";
|
||||||
|
INSERT INTO t8 VALUES (1,1);
|
||||||
|
INSERT INTO t8 VALUES (2,2);
|
||||||
|
INSERT INTO t8 VALUES (3,3);
|
||||||
|
INSERT INTO t8 VALUES (4,4);
|
||||||
|
INSERT INTO t8 VALUES (5,5);
|
||||||
|
INSERT INTO t8 VALUES (6,6);
|
||||||
|
INSERT INTO t8 VALUES (7,7);
|
||||||
|
INSERT INTO t8 VALUES (8,8);
|
||||||
|
UPDATE t7 SET b=9 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=10 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=11 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (12,12);
|
||||||
|
INSERT INTO t8 VALUES (13,13);
|
||||||
|
UPDATE t7 SET b=14 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=15 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (16,16);
|
||||||
|
UPDATE t7 SET b=17 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (18,18);
|
||||||
|
INSERT INTO t8 VALUES (19,19);
|
||||||
|
UPDATE t7 SET b=20 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (21,21);
|
||||||
|
UPDATE t7 SET b=22 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (23,24);
|
||||||
|
INSERT INTO t8 VALUES (24,24);
|
||||||
|
UPDATE t7 SET b=25 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (26,26);
|
||||||
|
UPDATE t7 SET b=27 WHERE a=3;
|
||||||
|
BEGIN;
|
||||||
|
INSERT INTO t8 VALUES (28,28);
|
||||||
|
INSERT INTO t8 VALUES (29,28), (30,28);
|
||||||
|
INSERT INTO t8 VALUES (31,28);
|
||||||
|
INSERT INTO t8 VALUES (32,28);
|
||||||
|
INSERT INTO t8 VALUES (33,28);
|
||||||
|
INSERT INTO t8 VALUES (34,28);
|
||||||
|
INSERT INTO t8 VALUES (35,28);
|
||||||
|
INSERT INTO t8 VALUES (36,28);
|
||||||
|
INSERT INTO t8 VALUES (37,28);
|
||||||
|
INSERT INTO t8 VALUES (38,28);
|
||||||
|
INSERT INTO t8 VALUES (39,28);
|
||||||
|
INSERT INTO t8 VALUES (40,28);
|
||||||
|
INSERT INTO t8 VALUES (41,28);
|
||||||
|
INSERT INTO t8 VALUES (42,28);
|
||||||
|
COMMIT;
|
||||||
|
SET @commit_id=43;
|
||||||
|
INSERT INTO t8 VALUES (43,43);
|
||||||
|
INSERT INTO t8 VALUES (44,44);
|
||||||
|
UPDATE t7 SET b=45 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (46,46);
|
||||||
|
INSERT INTO t8 VALUES (47,47);
|
||||||
|
UPDATE t7 SET b=48 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (49,49);
|
||||||
|
INSERT INTO t8 VALUES (50,50);
|
||||||
|
SET @commit_id=44;
|
||||||
|
INSERT INTO t8 VALUES (51,51);
|
||||||
|
INSERT INTO t8 VALUES (52,52);
|
||||||
|
UPDATE t7 SET b=53 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (54,54);
|
||||||
|
INSERT INTO t8 VALUES (55,55);
|
||||||
|
UPDATE t7 SET b=56 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (57,57);
|
||||||
|
UPDATE t7 SET b=58 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (58,58);
|
||||||
|
INSERT INTO t8 VALUES (59,59);
|
||||||
|
INSERT INTO t8 VALUES (60,60);
|
||||||
|
INSERT INTO t8 VALUES (61,61);
|
||||||
|
UPDATE t7 SET b=62 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (63,63);
|
||||||
|
INSERT INTO t8 VALUES (64,64);
|
||||||
|
INSERT INTO t8 VALUES (65,65);
|
||||||
|
INSERT INTO t8 VALUES (66,66);
|
||||||
|
UPDATE t7 SET b=67 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (68,68);
|
||||||
|
UPDATE t7 SET b=69 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=70 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=71 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (72,72);
|
||||||
|
UPDATE t7 SET b=73 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=74 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=75 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=76 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (77,77);
|
||||||
|
UPDATE t7 SET b=78 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (79,79);
|
||||||
|
UPDATE t7 SET b=80 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (81,81);
|
||||||
|
UPDATE t7 SET b=82 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (83,83);
|
||||||
|
UPDATE t7 SET b=84 WHERE a=3;
|
||||||
|
SET @commit_id=45;
|
||||||
|
INSERT INTO t8 VALUES (85,85);
|
||||||
|
UPDATE t7 SET b=86 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (87,87);
|
||||||
|
SET @commit_id=46;
|
||||||
|
INSERT INTO t8 VALUES (88,88);
|
||||||
|
INSERT INTO t8 VALUES (89,89);
|
||||||
|
INSERT INTO t8 VALUES (90,90);
|
||||||
|
SET SESSION debug_dbug=@old_dbug;
|
||||||
|
INSERT INTO t8 VALUES (91,91);
|
||||||
|
INSERT INTO t8 VALUES (92,92);
|
||||||
|
INSERT INTO t8 VALUES (93,93);
|
||||||
|
INSERT INTO t8 VALUES (94,94);
|
||||||
|
INSERT INTO t8 VALUES (95,95);
|
||||||
|
INSERT INTO t8 VALUES (96,96);
|
||||||
|
INSERT INTO t8 VALUES (97,97);
|
||||||
|
INSERT INTO t8 VALUES (98,98);
|
||||||
|
INSERT INTO t8 VALUES (99,99);
|
||||||
|
SELECT * FROM t7 ORDER BY a;
|
||||||
|
a b
|
||||||
|
1 1
|
||||||
|
2 2
|
||||||
|
3 86
|
||||||
|
4 4
|
||||||
|
5 5
|
||||||
|
SELECT * FROM t8 ORDER BY a;
|
||||||
|
a b
|
||||||
|
1 1
|
||||||
|
2 2
|
||||||
|
3 3
|
||||||
|
4 4
|
||||||
|
5 5
|
||||||
|
6 6
|
||||||
|
7 7
|
||||||
|
8 8
|
||||||
|
12 12
|
||||||
|
13 13
|
||||||
|
16 16
|
||||||
|
18 18
|
||||||
|
19 19
|
||||||
|
21 21
|
||||||
|
23 24
|
||||||
|
24 24
|
||||||
|
26 26
|
||||||
|
28 28
|
||||||
|
29 28
|
||||||
|
30 28
|
||||||
|
31 28
|
||||||
|
32 28
|
||||||
|
33 28
|
||||||
|
34 28
|
||||||
|
35 28
|
||||||
|
36 28
|
||||||
|
37 28
|
||||||
|
38 28
|
||||||
|
39 28
|
||||||
|
40 28
|
||||||
|
41 28
|
||||||
|
42 28
|
||||||
|
43 43
|
||||||
|
44 44
|
||||||
|
46 46
|
||||||
|
47 47
|
||||||
|
49 49
|
||||||
|
50 50
|
||||||
|
51 51
|
||||||
|
52 52
|
||||||
|
54 54
|
||||||
|
55 55
|
||||||
|
57 57
|
||||||
|
58 58
|
||||||
|
59 59
|
||||||
|
60 60
|
||||||
|
61 61
|
||||||
|
63 63
|
||||||
|
64 64
|
||||||
|
65 65
|
||||||
|
66 66
|
||||||
|
68 68
|
||||||
|
72 72
|
||||||
|
77 77
|
||||||
|
79 79
|
||||||
|
81 81
|
||||||
|
83 83
|
||||||
|
85 85
|
||||||
|
87 87
|
||||||
|
88 88
|
||||||
|
89 89
|
||||||
|
90 90
|
||||||
|
91 91
|
||||||
|
92 92
|
||||||
|
93 93
|
||||||
|
94 94
|
||||||
|
95 95
|
||||||
|
96 96
|
||||||
|
97 97
|
||||||
|
98 98
|
||||||
|
99 99
|
||||||
|
include/save_master_gtid.inc
|
||||||
|
connection server_2;
|
||||||
|
include/start_slave.inc
|
||||||
|
include/sync_with_master_gtid.inc
|
||||||
|
SELECT * FROM t7 ORDER BY a;
|
||||||
|
a b
|
||||||
|
1 1
|
||||||
|
2 2
|
||||||
|
3 86
|
||||||
|
4 4
|
||||||
|
5 5
|
||||||
|
SELECT * FROM t8 ORDER BY a;
|
||||||
|
a b
|
||||||
|
1 1
|
||||||
|
2 2
|
||||||
|
3 3
|
||||||
|
4 4
|
||||||
|
5 5
|
||||||
|
6 6
|
||||||
|
7 7
|
||||||
|
8 8
|
||||||
|
12 12
|
||||||
|
13 13
|
||||||
|
16 16
|
||||||
|
18 18
|
||||||
|
19 19
|
||||||
|
21 21
|
||||||
|
23 24
|
||||||
|
24 24
|
||||||
|
26 26
|
||||||
|
28 28
|
||||||
|
29 28
|
||||||
|
30 28
|
||||||
|
31 28
|
||||||
|
32 28
|
||||||
|
33 28
|
||||||
|
34 28
|
||||||
|
35 28
|
||||||
|
36 28
|
||||||
|
37 28
|
||||||
|
38 28
|
||||||
|
39 28
|
||||||
|
40 28
|
||||||
|
41 28
|
||||||
|
42 28
|
||||||
|
43 43
|
||||||
|
44 44
|
||||||
|
46 46
|
||||||
|
47 47
|
||||||
|
49 49
|
||||||
|
50 50
|
||||||
|
51 51
|
||||||
|
52 52
|
||||||
|
54 54
|
||||||
|
55 55
|
||||||
|
57 57
|
||||||
|
58 58
|
||||||
|
59 59
|
||||||
|
60 60
|
||||||
|
61 61
|
||||||
|
63 63
|
||||||
|
64 64
|
||||||
|
65 65
|
||||||
|
66 66
|
||||||
|
68 68
|
||||||
|
72 72
|
||||||
|
77 77
|
||||||
|
79 79
|
||||||
|
81 81
|
||||||
|
83 83
|
||||||
|
85 85
|
||||||
|
87 87
|
||||||
|
88 88
|
||||||
|
89 89
|
||||||
|
90 90
|
||||||
|
91 91
|
||||||
|
92 92
|
||||||
|
93 93
|
||||||
|
94 94
|
||||||
|
95 95
|
||||||
|
96 96
|
||||||
|
97 97
|
||||||
|
98 98
|
||||||
|
99 99
|
||||||
|
connection server_2;
|
||||||
|
include/stop_slave.inc
|
||||||
|
SET GLOBAL slave_parallel_threads=@old_parallel_threads;
|
||||||
|
SET GLOBAL slave_transaction_retries=@old_retries;
|
||||||
|
include/start_slave.inc
|
||||||
|
SET DEBUG_SYNC= 'RESET';
|
||||||
|
connection server_1;
|
||||||
|
DROP TABLE if exists t1,t2,t3,t4,t5,t6,t7,t8;
|
||||||
|
Warnings:
|
||||||
|
Note 1051 Unknown table 'test.t1'
|
||||||
|
Note 1051 Unknown table 'test.t2'
|
||||||
|
Note 1051 Unknown table 'test.t3'
|
||||||
|
Note 1051 Unknown table 'test.t4'
|
||||||
|
Note 1051 Unknown table 'test.t5'
|
||||||
|
Note 1051 Unknown table 'test.t6'
|
||||||
|
SET DEBUG_SYNC= 'RESET';
|
||||||
|
include/rpl_end.inc
|
||||||
@ -1504,303 +1504,11 @@ a
|
|||||||
1044
|
1044
|
||||||
1045
|
1045
|
||||||
1046
|
1046
|
||||||
include/stop_slave.inc
|
|
||||||
SET GLOBAL slave_parallel_mode='conservative';
|
|
||||||
include/start_slave.inc
|
|
||||||
*** MDEV-7847: "Slave worker thread retried transaction 10 time(s) in vain, giving up", followed by replication hanging ***
|
|
||||||
*** MDEV-7882: Excessive transaction retry in parallel replication ***
|
|
||||||
connection server_1;
|
|
||||||
CREATE TABLE t7 (a int PRIMARY KEY, b INT) ENGINE=InnoDB;
|
|
||||||
CREATE TABLE t8 (a int PRIMARY KEY, b INT) ENGINE=InnoDB;
|
|
||||||
connection server_2;
|
|
||||||
include/stop_slave.inc
|
|
||||||
SET GLOBAL slave_parallel_threads=40;
|
|
||||||
SELECT @old_retries:=@@GLOBAL.slave_transaction_retries;
|
|
||||||
@old_retries:=@@GLOBAL.slave_transaction_retries
|
|
||||||
10
|
|
||||||
SET GLOBAL slave_transaction_retries= 5;
|
|
||||||
connection server_1;
|
|
||||||
INSERT INTO t7 VALUES (1,1), (2,2), (3,3), (4,4), (5,5);
|
|
||||||
SET @old_dbug= @@SESSION.debug_dbug;
|
|
||||||
SET @commit_id= 42;
|
|
||||||
SET SESSION debug_dbug="+d,binlog_force_commit_id";
|
|
||||||
INSERT INTO t8 VALUES (1,1);
|
|
||||||
INSERT INTO t8 VALUES (2,2);
|
|
||||||
INSERT INTO t8 VALUES (3,3);
|
|
||||||
INSERT INTO t8 VALUES (4,4);
|
|
||||||
INSERT INTO t8 VALUES (5,5);
|
|
||||||
INSERT INTO t8 VALUES (6,6);
|
|
||||||
INSERT INTO t8 VALUES (7,7);
|
|
||||||
INSERT INTO t8 VALUES (8,8);
|
|
||||||
UPDATE t7 SET b=9 WHERE a=3;
|
|
||||||
UPDATE t7 SET b=10 WHERE a=3;
|
|
||||||
UPDATE t7 SET b=11 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (12,12);
|
|
||||||
INSERT INTO t8 VALUES (13,13);
|
|
||||||
UPDATE t7 SET b=14 WHERE a=3;
|
|
||||||
UPDATE t7 SET b=15 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (16,16);
|
|
||||||
UPDATE t7 SET b=17 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (18,18);
|
|
||||||
INSERT INTO t8 VALUES (19,19);
|
|
||||||
UPDATE t7 SET b=20 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (21,21);
|
|
||||||
UPDATE t7 SET b=22 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (23,24);
|
|
||||||
INSERT INTO t8 VALUES (24,24);
|
|
||||||
UPDATE t7 SET b=25 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (26,26);
|
|
||||||
UPDATE t7 SET b=27 WHERE a=3;
|
|
||||||
BEGIN;
|
|
||||||
INSERT INTO t8 VALUES (28,28);
|
|
||||||
INSERT INTO t8 VALUES (29,28), (30,28);
|
|
||||||
INSERT INTO t8 VALUES (31,28);
|
|
||||||
INSERT INTO t8 VALUES (32,28);
|
|
||||||
INSERT INTO t8 VALUES (33,28);
|
|
||||||
INSERT INTO t8 VALUES (34,28);
|
|
||||||
INSERT INTO t8 VALUES (35,28);
|
|
||||||
INSERT INTO t8 VALUES (36,28);
|
|
||||||
INSERT INTO t8 VALUES (37,28);
|
|
||||||
INSERT INTO t8 VALUES (38,28);
|
|
||||||
INSERT INTO t8 VALUES (39,28);
|
|
||||||
INSERT INTO t8 VALUES (40,28);
|
|
||||||
INSERT INTO t8 VALUES (41,28);
|
|
||||||
INSERT INTO t8 VALUES (42,28);
|
|
||||||
COMMIT;
|
|
||||||
SET @commit_id=43;
|
|
||||||
INSERT INTO t8 VALUES (43,43);
|
|
||||||
INSERT INTO t8 VALUES (44,44);
|
|
||||||
UPDATE t7 SET b=45 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (46,46);
|
|
||||||
INSERT INTO t8 VALUES (47,47);
|
|
||||||
UPDATE t7 SET b=48 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (49,49);
|
|
||||||
INSERT INTO t8 VALUES (50,50);
|
|
||||||
SET @commit_id=44;
|
|
||||||
INSERT INTO t8 VALUES (51,51);
|
|
||||||
INSERT INTO t8 VALUES (52,52);
|
|
||||||
UPDATE t7 SET b=53 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (54,54);
|
|
||||||
INSERT INTO t8 VALUES (55,55);
|
|
||||||
UPDATE t7 SET b=56 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (57,57);
|
|
||||||
UPDATE t7 SET b=58 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (58,58);
|
|
||||||
INSERT INTO t8 VALUES (59,59);
|
|
||||||
INSERT INTO t8 VALUES (60,60);
|
|
||||||
INSERT INTO t8 VALUES (61,61);
|
|
||||||
UPDATE t7 SET b=62 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (63,63);
|
|
||||||
INSERT INTO t8 VALUES (64,64);
|
|
||||||
INSERT INTO t8 VALUES (65,65);
|
|
||||||
INSERT INTO t8 VALUES (66,66);
|
|
||||||
UPDATE t7 SET b=67 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (68,68);
|
|
||||||
UPDATE t7 SET b=69 WHERE a=3;
|
|
||||||
UPDATE t7 SET b=70 WHERE a=3;
|
|
||||||
UPDATE t7 SET b=71 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (72,72);
|
|
||||||
UPDATE t7 SET b=73 WHERE a=3;
|
|
||||||
UPDATE t7 SET b=74 WHERE a=3;
|
|
||||||
UPDATE t7 SET b=75 WHERE a=3;
|
|
||||||
UPDATE t7 SET b=76 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (77,77);
|
|
||||||
UPDATE t7 SET b=78 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (79,79);
|
|
||||||
UPDATE t7 SET b=80 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (81,81);
|
|
||||||
UPDATE t7 SET b=82 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (83,83);
|
|
||||||
UPDATE t7 SET b=84 WHERE a=3;
|
|
||||||
SET @commit_id=45;
|
|
||||||
INSERT INTO t8 VALUES (85,85);
|
|
||||||
UPDATE t7 SET b=86 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (87,87);
|
|
||||||
SET @commit_id=46;
|
|
||||||
INSERT INTO t8 VALUES (88,88);
|
|
||||||
INSERT INTO t8 VALUES (89,89);
|
|
||||||
INSERT INTO t8 VALUES (90,90);
|
|
||||||
SET SESSION debug_dbug=@old_dbug;
|
|
||||||
INSERT INTO t8 VALUES (91,91);
|
|
||||||
INSERT INTO t8 VALUES (92,92);
|
|
||||||
INSERT INTO t8 VALUES (93,93);
|
|
||||||
INSERT INTO t8 VALUES (94,94);
|
|
||||||
INSERT INTO t8 VALUES (95,95);
|
|
||||||
INSERT INTO t8 VALUES (96,96);
|
|
||||||
INSERT INTO t8 VALUES (97,97);
|
|
||||||
INSERT INTO t8 VALUES (98,98);
|
|
||||||
INSERT INTO t8 VALUES (99,99);
|
|
||||||
SELECT * FROM t7 ORDER BY a;
|
|
||||||
a b
|
|
||||||
1 1
|
|
||||||
2 2
|
|
||||||
3 86
|
|
||||||
4 4
|
|
||||||
5 5
|
|
||||||
SELECT * FROM t8 ORDER BY a;
|
|
||||||
a b
|
|
||||||
1 1
|
|
||||||
2 2
|
|
||||||
3 3
|
|
||||||
4 4
|
|
||||||
5 5
|
|
||||||
6 6
|
|
||||||
7 7
|
|
||||||
8 8
|
|
||||||
12 12
|
|
||||||
13 13
|
|
||||||
16 16
|
|
||||||
18 18
|
|
||||||
19 19
|
|
||||||
21 21
|
|
||||||
23 24
|
|
||||||
24 24
|
|
||||||
26 26
|
|
||||||
28 28
|
|
||||||
29 28
|
|
||||||
30 28
|
|
||||||
31 28
|
|
||||||
32 28
|
|
||||||
33 28
|
|
||||||
34 28
|
|
||||||
35 28
|
|
||||||
36 28
|
|
||||||
37 28
|
|
||||||
38 28
|
|
||||||
39 28
|
|
||||||
40 28
|
|
||||||
41 28
|
|
||||||
42 28
|
|
||||||
43 43
|
|
||||||
44 44
|
|
||||||
46 46
|
|
||||||
47 47
|
|
||||||
49 49
|
|
||||||
50 50
|
|
||||||
51 51
|
|
||||||
52 52
|
|
||||||
54 54
|
|
||||||
55 55
|
|
||||||
57 57
|
|
||||||
58 58
|
|
||||||
59 59
|
|
||||||
60 60
|
|
||||||
61 61
|
|
||||||
63 63
|
|
||||||
64 64
|
|
||||||
65 65
|
|
||||||
66 66
|
|
||||||
68 68
|
|
||||||
72 72
|
|
||||||
77 77
|
|
||||||
79 79
|
|
||||||
81 81
|
|
||||||
83 83
|
|
||||||
85 85
|
|
||||||
87 87
|
|
||||||
88 88
|
|
||||||
89 89
|
|
||||||
90 90
|
|
||||||
91 91
|
|
||||||
92 92
|
|
||||||
93 93
|
|
||||||
94 94
|
|
||||||
95 95
|
|
||||||
96 96
|
|
||||||
97 97
|
|
||||||
98 98
|
|
||||||
99 99
|
|
||||||
include/save_master_gtid.inc
|
|
||||||
connection server_2;
|
|
||||||
include/start_slave.inc
|
|
||||||
include/sync_with_master_gtid.inc
|
|
||||||
SELECT * FROM t7 ORDER BY a;
|
|
||||||
a b
|
|
||||||
1 1
|
|
||||||
2 2
|
|
||||||
3 86
|
|
||||||
4 4
|
|
||||||
5 5
|
|
||||||
SELECT * FROM t8 ORDER BY a;
|
|
||||||
a b
|
|
||||||
1 1
|
|
||||||
2 2
|
|
||||||
3 3
|
|
||||||
4 4
|
|
||||||
5 5
|
|
||||||
6 6
|
|
||||||
7 7
|
|
||||||
8 8
|
|
||||||
12 12
|
|
||||||
13 13
|
|
||||||
16 16
|
|
||||||
18 18
|
|
||||||
19 19
|
|
||||||
21 21
|
|
||||||
23 24
|
|
||||||
24 24
|
|
||||||
26 26
|
|
||||||
28 28
|
|
||||||
29 28
|
|
||||||
30 28
|
|
||||||
31 28
|
|
||||||
32 28
|
|
||||||
33 28
|
|
||||||
34 28
|
|
||||||
35 28
|
|
||||||
36 28
|
|
||||||
37 28
|
|
||||||
38 28
|
|
||||||
39 28
|
|
||||||
40 28
|
|
||||||
41 28
|
|
||||||
42 28
|
|
||||||
43 43
|
|
||||||
44 44
|
|
||||||
46 46
|
|
||||||
47 47
|
|
||||||
49 49
|
|
||||||
50 50
|
|
||||||
51 51
|
|
||||||
52 52
|
|
||||||
54 54
|
|
||||||
55 55
|
|
||||||
57 57
|
|
||||||
58 58
|
|
||||||
59 59
|
|
||||||
60 60
|
|
||||||
61 61
|
|
||||||
63 63
|
|
||||||
64 64
|
|
||||||
65 65
|
|
||||||
66 66
|
|
||||||
68 68
|
|
||||||
72 72
|
|
||||||
77 77
|
|
||||||
79 79
|
|
||||||
81 81
|
|
||||||
83 83
|
|
||||||
85 85
|
|
||||||
87 87
|
|
||||||
88 88
|
|
||||||
89 89
|
|
||||||
90 90
|
|
||||||
91 91
|
|
||||||
92 92
|
|
||||||
93 93
|
|
||||||
94 94
|
|
||||||
95 95
|
|
||||||
96 96
|
|
||||||
97 97
|
|
||||||
98 98
|
|
||||||
99 99
|
|
||||||
include/stop_slave.inc
|
|
||||||
SET GLOBAL slave_transaction_retries= @old_retries;
|
|
||||||
SET GLOBAL slave_parallel_threads=10;
|
|
||||||
include/start_slave.inc
|
|
||||||
*** MDEV-7888: ANALYZE TABLE does wakeup_subsequent_commits(), causing wrong binlog order and parallel replication hang ***
|
*** MDEV-7888: ANALYZE TABLE does wakeup_subsequent_commits(), causing wrong binlog order and parallel replication hang ***
|
||||||
connection server_2;
|
connection server_2;
|
||||||
include/stop_slave.inc
|
include/stop_slave.inc
|
||||||
|
SET GLOBAL slave_parallel_mode='conservative';
|
||||||
|
SET GLOBAL slave_parallel_threads=10;
|
||||||
SET @old_dbug= @@GLOBAL.debug_dbug;
|
SET @old_dbug= @@GLOBAL.debug_dbug;
|
||||||
SET GLOBAL debug_dbug= '+d,inject_analyze_table_sleep';
|
SET GLOBAL debug_dbug= '+d,inject_analyze_table_sleep';
|
||||||
connection server_1;
|
connection server_1;
|
||||||
@ -1949,49 +1657,6 @@ include/stop_slave.inc
|
|||||||
SET GLOBAL debug_dbug= @old_debg;
|
SET GLOBAL debug_dbug= @old_debg;
|
||||||
SET GLOBAL max_relay_log_size= @old_max;
|
SET GLOBAL max_relay_log_size= @old_max;
|
||||||
include/start_slave.inc
|
include/start_slave.inc
|
||||||
*** MDEV-8302: Duplicate key with parallel replication ***
|
|
||||||
connection server_2;
|
|
||||||
include/stop_slave.inc
|
|
||||||
/* Inject a small sleep which makes the race easier to hit. */
|
|
||||||
SET @old_dbug=@@GLOBAL.debug_dbug;
|
|
||||||
SET GLOBAL debug_dbug="+d,inject_mdev8302";
|
|
||||||
connection server_1;
|
|
||||||
INSERT INTO t7 VALUES (100,1), (101,2), (102,3), (103,4), (104,5);
|
|
||||||
SET @old_dbug= @@SESSION.debug_dbug;
|
|
||||||
SET @commit_id= 20000;
|
|
||||||
SET SESSION debug_dbug="+d,binlog_force_commit_id";
|
|
||||||
SET SESSION debug_dbug=@old_dbug;
|
|
||||||
SELECT * FROM t7 ORDER BY a;
|
|
||||||
a b
|
|
||||||
1 1
|
|
||||||
2 2
|
|
||||||
3 86
|
|
||||||
4 4
|
|
||||||
5 5
|
|
||||||
100 5
|
|
||||||
101 1
|
|
||||||
102 2
|
|
||||||
103 3
|
|
||||||
104 4
|
|
||||||
include/save_master_gtid.inc
|
|
||||||
connection server_2;
|
|
||||||
include/start_slave.inc
|
|
||||||
include/sync_with_master_gtid.inc
|
|
||||||
SELECT * FROM t7 ORDER BY a;
|
|
||||||
a b
|
|
||||||
1 1
|
|
||||||
2 2
|
|
||||||
3 86
|
|
||||||
4 4
|
|
||||||
5 5
|
|
||||||
100 5
|
|
||||||
101 1
|
|
||||||
102 2
|
|
||||||
103 3
|
|
||||||
104 4
|
|
||||||
include/stop_slave.inc
|
|
||||||
SET GLOBAL debug_dbug=@old_dbug;
|
|
||||||
include/start_slave.inc
|
|
||||||
*** MDEV-8725: Assertion on ROLLBACK statement in the binary log ***
|
*** MDEV-8725: Assertion on ROLLBACK statement in the binary log ***
|
||||||
connection server_1;
|
connection server_1;
|
||||||
BEGIN;
|
BEGIN;
|
||||||
@ -2019,6 +1684,6 @@ include/start_slave.inc
|
|||||||
SET DEBUG_SYNC= 'RESET';
|
SET DEBUG_SYNC= 'RESET';
|
||||||
connection server_1;
|
connection server_1;
|
||||||
DROP function foo;
|
DROP function foo;
|
||||||
DROP TABLE t1,t2,t3,t4,t5,t6,t7,t8;
|
DROP TABLE t1,t2,t3,t4,t5,t6;
|
||||||
SET DEBUG_SYNC= 'RESET';
|
SET DEBUG_SYNC= 'RESET';
|
||||||
include/rpl_end.inc
|
include/rpl_end.inc
|
||||||
|
|||||||
333
mysql-test/suite/rpl/r/rpl_parallel_conflicts.result
Normal file
333
mysql-test/suite/rpl/r/rpl_parallel_conflicts.result
Normal file
@ -0,0 +1,333 @@
|
|||||||
|
include/master-slave.inc
|
||||||
|
[connection master]
|
||||||
|
*** MDEV-7847: "Slave worker thread retried transaction 10 time(s) in vain, giving up", followed by replication hanging ***
|
||||||
|
*** MDEV-7882: Excessive transaction retry in parallel replication ***
|
||||||
|
connection server_1;
|
||||||
|
ALTER TABLE mysql.gtid_slave_pos ENGINE=InnoDB;
|
||||||
|
CREATE TABLE t7 (a int PRIMARY KEY, b INT) ENGINE=InnoDB;
|
||||||
|
CREATE TABLE t8 (a int PRIMARY KEY, b INT) ENGINE=InnoDB;
|
||||||
|
connection server_2;
|
||||||
|
include/stop_slave.inc
|
||||||
|
connection server_1;
|
||||||
|
INSERT INTO t7 VALUES (1,1), (2,2), (3,3), (4,4), (5,5);
|
||||||
|
SET @old_dbug= @@SESSION.debug_dbug;
|
||||||
|
SET @commit_id= 42;
|
||||||
|
SET SESSION debug_dbug="+d,binlog_force_commit_id";
|
||||||
|
INSERT INTO t8 VALUES (1,1);
|
||||||
|
INSERT INTO t8 VALUES (2,2);
|
||||||
|
INSERT INTO t8 VALUES (3,3);
|
||||||
|
INSERT INTO t8 VALUES (4,4);
|
||||||
|
INSERT INTO t8 VALUES (5,5);
|
||||||
|
INSERT INTO t8 VALUES (6,6);
|
||||||
|
INSERT INTO t8 VALUES (7,7);
|
||||||
|
INSERT INTO t8 VALUES (8,8);
|
||||||
|
UPDATE t7 SET b=9 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=10 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=11 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (12,12);
|
||||||
|
INSERT INTO t8 VALUES (13,13);
|
||||||
|
UPDATE t7 SET b=14 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=15 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (16,16);
|
||||||
|
UPDATE t7 SET b=17 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (18,18);
|
||||||
|
INSERT INTO t8 VALUES (19,19);
|
||||||
|
UPDATE t7 SET b=20 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (21,21);
|
||||||
|
UPDATE t7 SET b=22 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (23,24);
|
||||||
|
INSERT INTO t8 VALUES (24,24);
|
||||||
|
UPDATE t7 SET b=25 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (26,26);
|
||||||
|
UPDATE t7 SET b=27 WHERE a=3;
|
||||||
|
BEGIN;
|
||||||
|
INSERT INTO t8 VALUES (28,28);
|
||||||
|
INSERT INTO t8 VALUES (29,28), (30,28);
|
||||||
|
INSERT INTO t8 VALUES (31,28);
|
||||||
|
INSERT INTO t8 VALUES (32,28);
|
||||||
|
INSERT INTO t8 VALUES (33,28);
|
||||||
|
INSERT INTO t8 VALUES (34,28);
|
||||||
|
INSERT INTO t8 VALUES (35,28);
|
||||||
|
INSERT INTO t8 VALUES (36,28);
|
||||||
|
INSERT INTO t8 VALUES (37,28);
|
||||||
|
INSERT INTO t8 VALUES (38,28);
|
||||||
|
INSERT INTO t8 VALUES (39,28);
|
||||||
|
INSERT INTO t8 VALUES (40,28);
|
||||||
|
INSERT INTO t8 VALUES (41,28);
|
||||||
|
INSERT INTO t8 VALUES (42,28);
|
||||||
|
COMMIT;
|
||||||
|
SET @commit_id=43;
|
||||||
|
INSERT INTO t8 VALUES (43,43);
|
||||||
|
INSERT INTO t8 VALUES (44,44);
|
||||||
|
UPDATE t7 SET b=45 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (46,46);
|
||||||
|
INSERT INTO t8 VALUES (47,47);
|
||||||
|
UPDATE t7 SET b=48 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (49,49);
|
||||||
|
INSERT INTO t8 VALUES (50,50);
|
||||||
|
SET @commit_id=44;
|
||||||
|
INSERT INTO t8 VALUES (51,51);
|
||||||
|
INSERT INTO t8 VALUES (52,52);
|
||||||
|
UPDATE t7 SET b=53 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (54,54);
|
||||||
|
INSERT INTO t8 VALUES (55,55);
|
||||||
|
UPDATE t7 SET b=56 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (57,57);
|
||||||
|
UPDATE t7 SET b=58 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (58,58);
|
||||||
|
INSERT INTO t8 VALUES (59,59);
|
||||||
|
INSERT INTO t8 VALUES (60,60);
|
||||||
|
INSERT INTO t8 VALUES (61,61);
|
||||||
|
UPDATE t7 SET b=62 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (63,63);
|
||||||
|
INSERT INTO t8 VALUES (64,64);
|
||||||
|
INSERT INTO t8 VALUES (65,65);
|
||||||
|
INSERT INTO t8 VALUES (66,66);
|
||||||
|
UPDATE t7 SET b=67 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (68,68);
|
||||||
|
UPDATE t7 SET b=69 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=70 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=71 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (72,72);
|
||||||
|
UPDATE t7 SET b=73 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=74 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=75 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=76 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (77,77);
|
||||||
|
UPDATE t7 SET b=78 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (79,79);
|
||||||
|
UPDATE t7 SET b=80 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (81,81);
|
||||||
|
UPDATE t7 SET b=82 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (83,83);
|
||||||
|
UPDATE t7 SET b=84 WHERE a=3;
|
||||||
|
SET @commit_id=45;
|
||||||
|
INSERT INTO t8 VALUES (85,85);
|
||||||
|
UPDATE t7 SET b=86 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (87,87);
|
||||||
|
SET @commit_id=46;
|
||||||
|
INSERT INTO t8 VALUES (88,88);
|
||||||
|
INSERT INTO t8 VALUES (89,89);
|
||||||
|
INSERT INTO t8 VALUES (90,90);
|
||||||
|
SET SESSION debug_dbug=@old_dbug;
|
||||||
|
INSERT INTO t8 VALUES (91,91);
|
||||||
|
INSERT INTO t8 VALUES (92,92);
|
||||||
|
INSERT INTO t8 VALUES (93,93);
|
||||||
|
INSERT INTO t8 VALUES (94,94);
|
||||||
|
INSERT INTO t8 VALUES (95,95);
|
||||||
|
INSERT INTO t8 VALUES (96,96);
|
||||||
|
INSERT INTO t8 VALUES (97,97);
|
||||||
|
INSERT INTO t8 VALUES (98,98);
|
||||||
|
INSERT INTO t8 VALUES (99,99);
|
||||||
|
SELECT * FROM t7 ORDER BY a;
|
||||||
|
a b
|
||||||
|
1 1
|
||||||
|
2 2
|
||||||
|
3 86
|
||||||
|
4 4
|
||||||
|
5 5
|
||||||
|
SELECT * FROM t8 ORDER BY a;
|
||||||
|
a b
|
||||||
|
1 1
|
||||||
|
2 2
|
||||||
|
3 3
|
||||||
|
4 4
|
||||||
|
5 5
|
||||||
|
6 6
|
||||||
|
7 7
|
||||||
|
8 8
|
||||||
|
12 12
|
||||||
|
13 13
|
||||||
|
16 16
|
||||||
|
18 18
|
||||||
|
19 19
|
||||||
|
21 21
|
||||||
|
23 24
|
||||||
|
24 24
|
||||||
|
26 26
|
||||||
|
28 28
|
||||||
|
29 28
|
||||||
|
30 28
|
||||||
|
31 28
|
||||||
|
32 28
|
||||||
|
33 28
|
||||||
|
34 28
|
||||||
|
35 28
|
||||||
|
36 28
|
||||||
|
37 28
|
||||||
|
38 28
|
||||||
|
39 28
|
||||||
|
40 28
|
||||||
|
41 28
|
||||||
|
42 28
|
||||||
|
43 43
|
||||||
|
44 44
|
||||||
|
46 46
|
||||||
|
47 47
|
||||||
|
49 49
|
||||||
|
50 50
|
||||||
|
51 51
|
||||||
|
52 52
|
||||||
|
54 54
|
||||||
|
55 55
|
||||||
|
57 57
|
||||||
|
58 58
|
||||||
|
59 59
|
||||||
|
60 60
|
||||||
|
61 61
|
||||||
|
63 63
|
||||||
|
64 64
|
||||||
|
65 65
|
||||||
|
66 66
|
||||||
|
68 68
|
||||||
|
72 72
|
||||||
|
77 77
|
||||||
|
79 79
|
||||||
|
81 81
|
||||||
|
83 83
|
||||||
|
85 85
|
||||||
|
87 87
|
||||||
|
88 88
|
||||||
|
89 89
|
||||||
|
90 90
|
||||||
|
91 91
|
||||||
|
92 92
|
||||||
|
93 93
|
||||||
|
94 94
|
||||||
|
95 95
|
||||||
|
96 96
|
||||||
|
97 97
|
||||||
|
98 98
|
||||||
|
99 99
|
||||||
|
include/save_master_gtid.inc
|
||||||
|
connection server_2;
|
||||||
|
include/start_slave.inc
|
||||||
|
include/sync_with_master_gtid.inc
|
||||||
|
SELECT * FROM t7 ORDER BY a;
|
||||||
|
a b
|
||||||
|
1 1
|
||||||
|
2 2
|
||||||
|
3 86
|
||||||
|
4 4
|
||||||
|
5 5
|
||||||
|
SELECT * FROM t8 ORDER BY a;
|
||||||
|
a b
|
||||||
|
1 1
|
||||||
|
2 2
|
||||||
|
3 3
|
||||||
|
4 4
|
||||||
|
5 5
|
||||||
|
6 6
|
||||||
|
7 7
|
||||||
|
8 8
|
||||||
|
12 12
|
||||||
|
13 13
|
||||||
|
16 16
|
||||||
|
18 18
|
||||||
|
19 19
|
||||||
|
21 21
|
||||||
|
23 24
|
||||||
|
24 24
|
||||||
|
26 26
|
||||||
|
28 28
|
||||||
|
29 28
|
||||||
|
30 28
|
||||||
|
31 28
|
||||||
|
32 28
|
||||||
|
33 28
|
||||||
|
34 28
|
||||||
|
35 28
|
||||||
|
36 28
|
||||||
|
37 28
|
||||||
|
38 28
|
||||||
|
39 28
|
||||||
|
40 28
|
||||||
|
41 28
|
||||||
|
42 28
|
||||||
|
43 43
|
||||||
|
44 44
|
||||||
|
46 46
|
||||||
|
47 47
|
||||||
|
49 49
|
||||||
|
50 50
|
||||||
|
51 51
|
||||||
|
52 52
|
||||||
|
54 54
|
||||||
|
55 55
|
||||||
|
57 57
|
||||||
|
58 58
|
||||||
|
59 59
|
||||||
|
60 60
|
||||||
|
61 61
|
||||||
|
63 63
|
||||||
|
64 64
|
||||||
|
65 65
|
||||||
|
66 66
|
||||||
|
68 68
|
||||||
|
72 72
|
||||||
|
77 77
|
||||||
|
79 79
|
||||||
|
81 81
|
||||||
|
83 83
|
||||||
|
85 85
|
||||||
|
87 87
|
||||||
|
88 88
|
||||||
|
89 89
|
||||||
|
90 90
|
||||||
|
91 91
|
||||||
|
92 92
|
||||||
|
93 93
|
||||||
|
94 94
|
||||||
|
95 95
|
||||||
|
96 96
|
||||||
|
97 97
|
||||||
|
98 98
|
||||||
|
99 99
|
||||||
|
*** MDEV-8302: Duplicate key with parallel replication ***
|
||||||
|
connection server_2;
|
||||||
|
include/stop_slave.inc
|
||||||
|
/* Inject a small sleep which makes the race easier to hit. */
|
||||||
|
SET @old_dbug=@@GLOBAL.debug_dbug;
|
||||||
|
SET GLOBAL debug_dbug="+d,inject_mdev8302";
|
||||||
|
connection server_1;
|
||||||
|
INSERT INTO t7 VALUES (100,1), (101,2), (102,3), (103,4), (104,5);
|
||||||
|
SET @old_dbug= @@SESSION.debug_dbug;
|
||||||
|
SET @commit_id= 20000;
|
||||||
|
SET SESSION debug_dbug="+d,binlog_force_commit_id";
|
||||||
|
SET SESSION debug_dbug=@old_dbug;
|
||||||
|
SELECT * FROM t7 ORDER BY a;
|
||||||
|
a b
|
||||||
|
1 1
|
||||||
|
2 2
|
||||||
|
3 86
|
||||||
|
4 4
|
||||||
|
5 5
|
||||||
|
100 5
|
||||||
|
101 1
|
||||||
|
102 2
|
||||||
|
103 3
|
||||||
|
104 4
|
||||||
|
include/save_master_gtid.inc
|
||||||
|
connection server_2;
|
||||||
|
include/start_slave.inc
|
||||||
|
include/sync_with_master_gtid.inc
|
||||||
|
SELECT * FROM t7 ORDER BY a;
|
||||||
|
a b
|
||||||
|
1 1
|
||||||
|
2 2
|
||||||
|
3 86
|
||||||
|
4 4
|
||||||
|
5 5
|
||||||
|
100 5
|
||||||
|
101 1
|
||||||
|
102 2
|
||||||
|
103 3
|
||||||
|
104 4
|
||||||
|
include/stop_slave.inc
|
||||||
|
SET GLOBAL debug_dbug=@old_dbug;
|
||||||
|
include/start_slave.inc
|
||||||
|
SET DEBUG_SYNC= 'RESET';
|
||||||
|
connection server_1;
|
||||||
|
DROP TABLE t7,t8;
|
||||||
|
SET DEBUG_SYNC= 'RESET';
|
||||||
|
include/rpl_end.inc
|
||||||
@ -1972,218 +1972,14 @@ SET GLOBAL slave_parallel_mode=minimal;
|
|||||||
--source include/start_slave.inc
|
--source include/start_slave.inc
|
||||||
--source include/sync_with_master_gtid.inc
|
--source include/sync_with_master_gtid.inc
|
||||||
SELECT * FROM t2 WHERE a >= 1040 ORDER BY a;
|
SELECT * FROM t2 WHERE a >= 1040 ORDER BY a;
|
||||||
--source include/stop_slave.inc
|
|
||||||
SET GLOBAL slave_parallel_mode='conservative';
|
|
||||||
--source include/start_slave.inc
|
|
||||||
|
|
||||||
|
|
||||||
--echo *** MDEV-7847: "Slave worker thread retried transaction 10 time(s) in vain, giving up", followed by replication hanging ***
|
|
||||||
--echo *** MDEV-7882: Excessive transaction retry in parallel replication ***
|
|
||||||
|
|
||||||
--connection server_1
|
|
||||||
CREATE TABLE t7 (a int PRIMARY KEY, b INT) ENGINE=InnoDB;
|
|
||||||
CREATE TABLE t8 (a int PRIMARY KEY, b INT) ENGINE=InnoDB;
|
|
||||||
--save_master_pos
|
|
||||||
|
|
||||||
--connection server_2
|
|
||||||
--sync_with_master
|
|
||||||
--source include/stop_slave.inc
|
|
||||||
SET GLOBAL slave_parallel_threads=40;
|
|
||||||
SELECT @old_retries:=@@GLOBAL.slave_transaction_retries;
|
|
||||||
SET GLOBAL slave_transaction_retries= 5;
|
|
||||||
|
|
||||||
|
|
||||||
# Using dbug error injection, we artificially create event groups with a lot of
|
|
||||||
# conflicting transactions in each event group. The bugs were originally seen
|
|
||||||
# "in the wild" with transactions that did not conflict on the master, and only
|
|
||||||
# conflicted very rarely on the slave (maybe some edge case with InnoDB btree
|
|
||||||
# page splits or something like that). The event groups here loosely reflect
|
|
||||||
# the structure of the original failure's group commits.
|
|
||||||
|
|
||||||
|
|
||||||
--connection server_1
|
|
||||||
INSERT INTO t7 VALUES (1,1), (2,2), (3,3), (4,4), (5,5);
|
|
||||||
SET @old_dbug= @@SESSION.debug_dbug;
|
|
||||||
SET @commit_id= 42;
|
|
||||||
SET SESSION debug_dbug="+d,binlog_force_commit_id";
|
|
||||||
INSERT INTO t8 VALUES (1,1);
|
|
||||||
INSERT INTO t8 VALUES (2,2);
|
|
||||||
INSERT INTO t8 VALUES (3,3);
|
|
||||||
INSERT INTO t8 VALUES (4,4);
|
|
||||||
INSERT INTO t8 VALUES (5,5);
|
|
||||||
INSERT INTO t8 VALUES (6,6);
|
|
||||||
INSERT INTO t8 VALUES (7,7);
|
|
||||||
INSERT INTO t8 VALUES (8,8);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=9 WHERE a=3;
|
|
||||||
UPDATE t7 SET b=10 WHERE a=3;
|
|
||||||
UPDATE t7 SET b=11 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (12,12);
|
|
||||||
INSERT INTO t8 VALUES (13,13);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=14 WHERE a=3;
|
|
||||||
UPDATE t7 SET b=15 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (16,16);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=17 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (18,18);
|
|
||||||
INSERT INTO t8 VALUES (19,19);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=20 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (21,21);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=22 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (23,24);
|
|
||||||
INSERT INTO t8 VALUES (24,24);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=25 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (26,26);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=27 WHERE a=3;
|
|
||||||
|
|
||||||
BEGIN;
|
|
||||||
INSERT INTO t8 VALUES (28,28);
|
|
||||||
INSERT INTO t8 VALUES (29,28), (30,28);
|
|
||||||
INSERT INTO t8 VALUES (31,28);
|
|
||||||
INSERT INTO t8 VALUES (32,28);
|
|
||||||
INSERT INTO t8 VALUES (33,28);
|
|
||||||
INSERT INTO t8 VALUES (34,28);
|
|
||||||
INSERT INTO t8 VALUES (35,28);
|
|
||||||
INSERT INTO t8 VALUES (36,28);
|
|
||||||
INSERT INTO t8 VALUES (37,28);
|
|
||||||
INSERT INTO t8 VALUES (38,28);
|
|
||||||
INSERT INTO t8 VALUES (39,28);
|
|
||||||
INSERT INTO t8 VALUES (40,28);
|
|
||||||
INSERT INTO t8 VALUES (41,28);
|
|
||||||
INSERT INTO t8 VALUES (42,28);
|
|
||||||
COMMIT;
|
|
||||||
|
|
||||||
|
|
||||||
SET @commit_id=43;
|
|
||||||
INSERT INTO t8 VALUES (43,43);
|
|
||||||
INSERT INTO t8 VALUES (44,44);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=45 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (46,46);
|
|
||||||
INSERT INTO t8 VALUES (47,47);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=48 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (49,49);
|
|
||||||
INSERT INTO t8 VALUES (50,50);
|
|
||||||
|
|
||||||
|
|
||||||
SET @commit_id=44;
|
|
||||||
INSERT INTO t8 VALUES (51,51);
|
|
||||||
INSERT INTO t8 VALUES (52,52);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=53 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (54,54);
|
|
||||||
INSERT INTO t8 VALUES (55,55);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=56 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (57,57);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=58 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (58,58);
|
|
||||||
INSERT INTO t8 VALUES (59,59);
|
|
||||||
INSERT INTO t8 VALUES (60,60);
|
|
||||||
INSERT INTO t8 VALUES (61,61);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=62 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (63,63);
|
|
||||||
INSERT INTO t8 VALUES (64,64);
|
|
||||||
INSERT INTO t8 VALUES (65,65);
|
|
||||||
INSERT INTO t8 VALUES (66,66);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=67 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (68,68);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=69 WHERE a=3;
|
|
||||||
UPDATE t7 SET b=70 WHERE a=3;
|
|
||||||
UPDATE t7 SET b=71 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (72,72);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=73 WHERE a=3;
|
|
||||||
UPDATE t7 SET b=74 WHERE a=3;
|
|
||||||
UPDATE t7 SET b=75 WHERE a=3;
|
|
||||||
UPDATE t7 SET b=76 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (77,77);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=78 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (79,79);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=80 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (81,81);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=82 WHERE a=3;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (83,83);
|
|
||||||
|
|
||||||
UPDATE t7 SET b=84 WHERE a=3;
|
|
||||||
|
|
||||||
|
|
||||||
SET @commit_id=45;
|
|
||||||
INSERT INTO t8 VALUES (85,85);
|
|
||||||
UPDATE t7 SET b=86 WHERE a=3;
|
|
||||||
INSERT INTO t8 VALUES (87,87);
|
|
||||||
|
|
||||||
|
|
||||||
SET @commit_id=46;
|
|
||||||
INSERT INTO t8 VALUES (88,88);
|
|
||||||
INSERT INTO t8 VALUES (89,89);
|
|
||||||
INSERT INTO t8 VALUES (90,90);
|
|
||||||
|
|
||||||
SET SESSION debug_dbug=@old_dbug;
|
|
||||||
|
|
||||||
INSERT INTO t8 VALUES (91,91);
|
|
||||||
INSERT INTO t8 VALUES (92,92);
|
|
||||||
INSERT INTO t8 VALUES (93,93);
|
|
||||||
INSERT INTO t8 VALUES (94,94);
|
|
||||||
INSERT INTO t8 VALUES (95,95);
|
|
||||||
INSERT INTO t8 VALUES (96,96);
|
|
||||||
INSERT INTO t8 VALUES (97,97);
|
|
||||||
INSERT INTO t8 VALUES (98,98);
|
|
||||||
INSERT INTO t8 VALUES (99,99);
|
|
||||||
|
|
||||||
|
|
||||||
SELECT * FROM t7 ORDER BY a;
|
|
||||||
SELECT * FROM t8 ORDER BY a;
|
|
||||||
--source include/save_master_gtid.inc
|
|
||||||
|
|
||||||
|
|
||||||
--connection server_2
|
|
||||||
--source include/start_slave.inc
|
|
||||||
--source include/sync_with_master_gtid.inc
|
|
||||||
SELECT * FROM t7 ORDER BY a;
|
|
||||||
SELECT * FROM t8 ORDER BY a;
|
|
||||||
|
|
||||||
--source include/stop_slave.inc
|
|
||||||
SET GLOBAL slave_transaction_retries= @old_retries;
|
|
||||||
SET GLOBAL slave_parallel_threads=10;
|
|
||||||
--source include/start_slave.inc
|
|
||||||
|
|
||||||
|
|
||||||
--echo *** MDEV-7888: ANALYZE TABLE does wakeup_subsequent_commits(), causing wrong binlog order and parallel replication hang ***
|
--echo *** MDEV-7888: ANALYZE TABLE does wakeup_subsequent_commits(), causing wrong binlog order and parallel replication hang ***
|
||||||
|
|
||||||
--connection server_2
|
--connection server_2
|
||||||
--source include/stop_slave.inc
|
--source include/stop_slave.inc
|
||||||
|
SET GLOBAL slave_parallel_mode='conservative';
|
||||||
|
SET GLOBAL slave_parallel_threads=10;
|
||||||
|
|
||||||
SET @old_dbug= @@GLOBAL.debug_dbug;
|
SET @old_dbug= @@GLOBAL.debug_dbug;
|
||||||
SET GLOBAL debug_dbug= '+d,inject_analyze_table_sleep';
|
SET GLOBAL debug_dbug= '+d,inject_analyze_table_sleep';
|
||||||
|
|
||||||
@ -2380,62 +2176,6 @@ SET GLOBAL debug_dbug= @old_debg;
|
|||||||
SET GLOBAL max_relay_log_size= @old_max;
|
SET GLOBAL max_relay_log_size= @old_max;
|
||||||
--source include/start_slave.inc
|
--source include/start_slave.inc
|
||||||
|
|
||||||
|
|
||||||
--echo *** MDEV-8302: Duplicate key with parallel replication ***
|
|
||||||
|
|
||||||
--connection server_2
|
|
||||||
--source include/stop_slave.inc
|
|
||||||
/* Inject a small sleep which makes the race easier to hit. */
|
|
||||||
SET @old_dbug=@@GLOBAL.debug_dbug;
|
|
||||||
SET GLOBAL debug_dbug="+d,inject_mdev8302";
|
|
||||||
|
|
||||||
|
|
||||||
--connection server_1
|
|
||||||
INSERT INTO t7 VALUES (100,1), (101,2), (102,3), (103,4), (104,5);
|
|
||||||
|
|
||||||
# Artificially create a bunch of group commits with conflicting transactions.
|
|
||||||
# The bug happened when T1 and T2 was in one group commit, and T3 was in the
|
|
||||||
# following group commit. T2 is a DELETE of a row with same primary key as a
|
|
||||||
# row that T3 inserts. T1 and T2 can conflict, causing T2 to be deadlock
|
|
||||||
# killed after starting to commit. The bug was that T2 could roll back before
|
|
||||||
# doing unmark_start_commit(); this could allow T3 to run before the retry
|
|
||||||
# of T2, causing duplicate key violation.
|
|
||||||
|
|
||||||
SET @old_dbug= @@SESSION.debug_dbug;
|
|
||||||
SET @commit_id= 20000;
|
|
||||||
SET SESSION debug_dbug="+d,binlog_force_commit_id";
|
|
||||||
|
|
||||||
--let $n = 100
|
|
||||||
--disable_query_log
|
|
||||||
while ($n)
|
|
||||||
{
|
|
||||||
eval UPDATE t7 SET b=b+1 WHERE a=100+($n MOD 5);
|
|
||||||
eval DELETE FROM t7 WHERE a=100+($n MOD 5);
|
|
||||||
|
|
||||||
SET @commit_id = @commit_id + 1;
|
|
||||||
eval INSERT INTO t7 VALUES (100+($n MOD 5), $n);
|
|
||||||
SET @commit_id = @commit_id + 1;
|
|
||||||
dec $n;
|
|
||||||
}
|
|
||||||
--enable_query_log
|
|
||||||
SET SESSION debug_dbug=@old_dbug;
|
|
||||||
|
|
||||||
|
|
||||||
SELECT * FROM t7 ORDER BY a;
|
|
||||||
--source include/save_master_gtid.inc
|
|
||||||
|
|
||||||
|
|
||||||
--connection server_2
|
|
||||||
--source include/start_slave.inc
|
|
||||||
--source include/sync_with_master_gtid.inc
|
|
||||||
SELECT * FROM t7 ORDER BY a;
|
|
||||||
|
|
||||||
--source include/stop_slave.inc
|
|
||||||
SET GLOBAL debug_dbug=@old_dbug;
|
|
||||||
--source include/start_slave.inc
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
--echo *** MDEV-8725: Assertion on ROLLBACK statement in the binary log ***
|
--echo *** MDEV-8725: Assertion on ROLLBACK statement in the binary log ***
|
||||||
--connection server_1
|
--connection server_1
|
||||||
# Inject an event group terminated by ROLLBACK, by mixing MyISAM and InnoDB
|
# Inject an event group terminated by ROLLBACK, by mixing MyISAM and InnoDB
|
||||||
@ -2457,7 +2197,6 @@ SELECT * FROM t2 WHERE a>=2000 ORDER BY a;
|
|||||||
SELECT * FROM t1 WHERE a>=2000 ORDER BY a;
|
SELECT * FROM t1 WHERE a>=2000 ORDER BY a;
|
||||||
SELECT * FROM t2 WHERE a>=2000 ORDER BY a;
|
SELECT * FROM t2 WHERE a>=2000 ORDER BY a;
|
||||||
|
|
||||||
|
|
||||||
# Clean up.
|
# Clean up.
|
||||||
--connection server_2
|
--connection server_2
|
||||||
--source include/stop_slave.inc
|
--source include/stop_slave.inc
|
||||||
@ -2467,7 +2206,7 @@ SET DEBUG_SYNC= 'RESET';
|
|||||||
|
|
||||||
--connection server_1
|
--connection server_1
|
||||||
DROP function foo;
|
DROP function foo;
|
||||||
DROP TABLE t1,t2,t3,t4,t5,t6,t7,t8;
|
DROP TABLE t1,t2,t3,t4,t5,t6;
|
||||||
SET DEBUG_SYNC= 'RESET';
|
SET DEBUG_SYNC= 'RESET';
|
||||||
|
|
||||||
--source include/rpl_end.inc
|
--source include/rpl_end.inc
|
||||||
|
|||||||
1
mysql-test/suite/rpl/t/rpl_parallel_conflicts-slave.opt
Normal file
1
mysql-test/suite/rpl/t/rpl_parallel_conflicts-slave.opt
Normal file
@ -0,0 +1 @@
|
|||||||
|
--slave_parallel_threads=40 --slave_parallel_mode=conservative --slave_transaction_retries=5
|
||||||
261
mysql-test/suite/rpl/t/rpl_parallel_conflicts.test
Normal file
261
mysql-test/suite/rpl/t/rpl_parallel_conflicts.test
Normal file
@ -0,0 +1,261 @@
|
|||||||
|
--source include/have_innodb.inc
|
||||||
|
--source include/have_debug.inc
|
||||||
|
--source include/have_debug_sync.inc
|
||||||
|
--source include/master-slave.inc
|
||||||
|
|
||||||
|
--echo *** MDEV-7847: "Slave worker thread retried transaction 10 time(s) in vain, giving up", followed by replication hanging ***
|
||||||
|
--echo *** MDEV-7882: Excessive transaction retry in parallel replication ***
|
||||||
|
|
||||||
|
--connection server_1
|
||||||
|
ALTER TABLE mysql.gtid_slave_pos ENGINE=InnoDB;
|
||||||
|
CREATE TABLE t7 (a int PRIMARY KEY, b INT) ENGINE=InnoDB;
|
||||||
|
CREATE TABLE t8 (a int PRIMARY KEY, b INT) ENGINE=InnoDB;
|
||||||
|
--save_master_pos
|
||||||
|
|
||||||
|
--connection server_2
|
||||||
|
--sync_with_master
|
||||||
|
--source include/stop_slave.inc
|
||||||
|
|
||||||
|
|
||||||
|
# Using dbug error injection, we artificially create event groups with a lot of
|
||||||
|
# conflicting transactions in each event group. The bugs were originally seen
|
||||||
|
# "in the wild" with transactions that did not conflict on the master, and only
|
||||||
|
# conflicted very rarely on the slave (maybe some edge case with InnoDB btree
|
||||||
|
# page splits or something like that). The event groups here loosely reflect
|
||||||
|
# the structure of the original failure's group commits.
|
||||||
|
|
||||||
|
|
||||||
|
--connection server_1
|
||||||
|
INSERT INTO t7 VALUES (1,1), (2,2), (3,3), (4,4), (5,5);
|
||||||
|
SET @old_dbug= @@SESSION.debug_dbug;
|
||||||
|
SET @commit_id= 42;
|
||||||
|
SET SESSION debug_dbug="+d,binlog_force_commit_id";
|
||||||
|
INSERT INTO t8 VALUES (1,1);
|
||||||
|
INSERT INTO t8 VALUES (2,2);
|
||||||
|
INSERT INTO t8 VALUES (3,3);
|
||||||
|
INSERT INTO t8 VALUES (4,4);
|
||||||
|
INSERT INTO t8 VALUES (5,5);
|
||||||
|
INSERT INTO t8 VALUES (6,6);
|
||||||
|
INSERT INTO t8 VALUES (7,7);
|
||||||
|
INSERT INTO t8 VALUES (8,8);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=9 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=10 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=11 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (12,12);
|
||||||
|
INSERT INTO t8 VALUES (13,13);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=14 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=15 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (16,16);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=17 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (18,18);
|
||||||
|
INSERT INTO t8 VALUES (19,19);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=20 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (21,21);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=22 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (23,24);
|
||||||
|
INSERT INTO t8 VALUES (24,24);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=25 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (26,26);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=27 WHERE a=3;
|
||||||
|
|
||||||
|
BEGIN;
|
||||||
|
INSERT INTO t8 VALUES (28,28);
|
||||||
|
INSERT INTO t8 VALUES (29,28), (30,28);
|
||||||
|
INSERT INTO t8 VALUES (31,28);
|
||||||
|
INSERT INTO t8 VALUES (32,28);
|
||||||
|
INSERT INTO t8 VALUES (33,28);
|
||||||
|
INSERT INTO t8 VALUES (34,28);
|
||||||
|
INSERT INTO t8 VALUES (35,28);
|
||||||
|
INSERT INTO t8 VALUES (36,28);
|
||||||
|
INSERT INTO t8 VALUES (37,28);
|
||||||
|
INSERT INTO t8 VALUES (38,28);
|
||||||
|
INSERT INTO t8 VALUES (39,28);
|
||||||
|
INSERT INTO t8 VALUES (40,28);
|
||||||
|
INSERT INTO t8 VALUES (41,28);
|
||||||
|
INSERT INTO t8 VALUES (42,28);
|
||||||
|
COMMIT;
|
||||||
|
|
||||||
|
|
||||||
|
SET @commit_id=43;
|
||||||
|
INSERT INTO t8 VALUES (43,43);
|
||||||
|
INSERT INTO t8 VALUES (44,44);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=45 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (46,46);
|
||||||
|
INSERT INTO t8 VALUES (47,47);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=48 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (49,49);
|
||||||
|
INSERT INTO t8 VALUES (50,50);
|
||||||
|
|
||||||
|
|
||||||
|
SET @commit_id=44;
|
||||||
|
INSERT INTO t8 VALUES (51,51);
|
||||||
|
INSERT INTO t8 VALUES (52,52);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=53 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (54,54);
|
||||||
|
INSERT INTO t8 VALUES (55,55);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=56 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (57,57);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=58 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (58,58);
|
||||||
|
INSERT INTO t8 VALUES (59,59);
|
||||||
|
INSERT INTO t8 VALUES (60,60);
|
||||||
|
INSERT INTO t8 VALUES (61,61);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=62 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (63,63);
|
||||||
|
INSERT INTO t8 VALUES (64,64);
|
||||||
|
INSERT INTO t8 VALUES (65,65);
|
||||||
|
INSERT INTO t8 VALUES (66,66);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=67 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (68,68);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=69 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=70 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=71 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (72,72);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=73 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=74 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=75 WHERE a=3;
|
||||||
|
UPDATE t7 SET b=76 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (77,77);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=78 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (79,79);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=80 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (81,81);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=82 WHERE a=3;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (83,83);
|
||||||
|
|
||||||
|
UPDATE t7 SET b=84 WHERE a=3;
|
||||||
|
|
||||||
|
|
||||||
|
SET @commit_id=45;
|
||||||
|
INSERT INTO t8 VALUES (85,85);
|
||||||
|
UPDATE t7 SET b=86 WHERE a=3;
|
||||||
|
INSERT INTO t8 VALUES (87,87);
|
||||||
|
|
||||||
|
|
||||||
|
SET @commit_id=46;
|
||||||
|
INSERT INTO t8 VALUES (88,88);
|
||||||
|
INSERT INTO t8 VALUES (89,89);
|
||||||
|
INSERT INTO t8 VALUES (90,90);
|
||||||
|
|
||||||
|
SET SESSION debug_dbug=@old_dbug;
|
||||||
|
|
||||||
|
INSERT INTO t8 VALUES (91,91);
|
||||||
|
INSERT INTO t8 VALUES (92,92);
|
||||||
|
INSERT INTO t8 VALUES (93,93);
|
||||||
|
INSERT INTO t8 VALUES (94,94);
|
||||||
|
INSERT INTO t8 VALUES (95,95);
|
||||||
|
INSERT INTO t8 VALUES (96,96);
|
||||||
|
INSERT INTO t8 VALUES (97,97);
|
||||||
|
INSERT INTO t8 VALUES (98,98);
|
||||||
|
INSERT INTO t8 VALUES (99,99);
|
||||||
|
|
||||||
|
|
||||||
|
SELECT * FROM t7 ORDER BY a;
|
||||||
|
SELECT * FROM t8 ORDER BY a;
|
||||||
|
--source include/save_master_gtid.inc
|
||||||
|
|
||||||
|
|
||||||
|
--connection server_2
|
||||||
|
--source include/start_slave.inc
|
||||||
|
--source include/sync_with_master_gtid.inc
|
||||||
|
SELECT * FROM t7 ORDER BY a;
|
||||||
|
SELECT * FROM t8 ORDER BY a;
|
||||||
|
|
||||||
|
--echo *** MDEV-8302: Duplicate key with parallel replication ***
|
||||||
|
|
||||||
|
--connection server_2
|
||||||
|
--source include/stop_slave.inc
|
||||||
|
/* Inject a small sleep which makes the race easier to hit. */
|
||||||
|
SET @old_dbug=@@GLOBAL.debug_dbug;
|
||||||
|
SET GLOBAL debug_dbug="+d,inject_mdev8302";
|
||||||
|
|
||||||
|
|
||||||
|
--connection server_1
|
||||||
|
INSERT INTO t7 VALUES (100,1), (101,2), (102,3), (103,4), (104,5);
|
||||||
|
|
||||||
|
# Artificially create a bunch of group commits with conflicting transactions.
|
||||||
|
# The bug happened when T1 and T2 was in one group commit, and T3 was in the
|
||||||
|
# following group commit. T2 is a DELETE of a row with same primary key as a
|
||||||
|
# row that T3 inserts. T1 and T2 can conflict, causing T2 to be deadlock
|
||||||
|
# killed after starting to commit. The bug was that T2 could roll back before
|
||||||
|
# doing unmark_start_commit(); this could allow T3 to run before the retry
|
||||||
|
# of T2, causing duplicate key violation.
|
||||||
|
|
||||||
|
SET @old_dbug= @@SESSION.debug_dbug;
|
||||||
|
SET @commit_id= 20000;
|
||||||
|
SET SESSION debug_dbug="+d,binlog_force_commit_id";
|
||||||
|
|
||||||
|
--let $n = 100
|
||||||
|
--disable_query_log
|
||||||
|
while ($n)
|
||||||
|
{
|
||||||
|
eval UPDATE t7 SET b=b+1 WHERE a=100+($n MOD 5);
|
||||||
|
eval DELETE FROM t7 WHERE a=100+($n MOD 5);
|
||||||
|
|
||||||
|
SET @commit_id = @commit_id + 1;
|
||||||
|
eval INSERT INTO t7 VALUES (100+($n MOD 5), $n);
|
||||||
|
SET @commit_id = @commit_id + 1;
|
||||||
|
dec $n;
|
||||||
|
}
|
||||||
|
--enable_query_log
|
||||||
|
SET SESSION debug_dbug=@old_dbug;
|
||||||
|
|
||||||
|
|
||||||
|
SELECT * FROM t7 ORDER BY a;
|
||||||
|
--source include/save_master_gtid.inc
|
||||||
|
|
||||||
|
|
||||||
|
--connection server_2
|
||||||
|
--source include/start_slave.inc
|
||||||
|
--source include/sync_with_master_gtid.inc
|
||||||
|
SELECT * FROM t7 ORDER BY a;
|
||||||
|
|
||||||
|
--source include/stop_slave.inc
|
||||||
|
SET GLOBAL debug_dbug=@old_dbug;
|
||||||
|
|
||||||
|
# Clean up.
|
||||||
|
--source include/start_slave.inc
|
||||||
|
SET DEBUG_SYNC= 'RESET';
|
||||||
|
|
||||||
|
--connection server_1
|
||||||
|
DROP TABLE t7,t8;
|
||||||
|
SET DEBUG_SYNC= 'RESET';
|
||||||
|
|
||||||
|
--source include/rpl_end.inc
|
||||||
Reference in New Issue
Block a user