Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
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.
- Loading branch information
Showing
6 changed files
with
913 additions
and
602 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -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 |
Oops, something went wrong.