mirror of
https://github.com/MariaDB/server.git
synced 2025-02-05 13:22:17 +01:00
714762ddb7
Description: ============ To change 'CONSERVATIVE' @@global.slave_parallel_mode default to 'OPTIMISTIC' in 10.5. @sql/sys_vars.cc Changed default parallel_mode to 'OPTIMISTIC' @sql/rpl_filter.cc Changed default parallel_mode to 'OPTIMISTIC' @sql/mysqld.cc Removed the initialization of 'SLAVE_PARALLEL_CONSERVATIVE' to 'opt_slave_parallel_mode' variable. @mysql-test/suite/rpl/t/rpl_parallel_mdev6589.test @mysql-test/suite/rpl/t/rpl_mdev6386.test Added 'mtr' suppression to ignore 'ER_PRIOR_COMMIT_FAILED'. In case of 'OPTIMISTIC' mode if a transaction gets killed during "wait_for_prior_commit" it results in above error "1964". Hence suppression needs to be added for this error. @mysql-test/suite/rpl/t/rpl_parallel_conflicts.test Test has a 'slave.opt' which explicitly sets slave_parallel_mode to 'conservative'. When the test ends this mode conflicts with new default mode. Hence check test case reports an error. The 'slave.opt' is removed and options are set and reset within test. @mysql-test/suite/multi_source/info_logs.result @mysql-test/suite/multi_source/reset_slave.result @mysql-test/suite/multi_source/simple.result Result content mismatch in "show slave status" output. This is expected as new slave_parallel_mode='OPTIMISTIC'. @mysql-test/include/check-testcase.test Updated default 'slave_parallel_mode' to 'optimistic'. Refactored rpl_parallel.test into following test cases. Test case 1: @mysql-test/suite/rpl/t/rpl_parallel_domain.test Test case 2: @mysql-test/suite/rpl/t/rpl_parallel_domain_slave_single_grp.test Test case 3: @mysql-test/suite/rpl/t/rpl_parallel_single_grpcmt.test Test case 4: @mysql-test/suite/rpl/t/rpl_parallel_stop_slave.test Test case 5: @mysql-test/suite/rpl/t/rpl_parallel_slave_bgc_kill.test Test case 6: @mysql-test/suite/rpl/t/rpl_parallel_gco_wait_kill.test Test case 7: @mysql-test/suite/rpl/t/rpl_parallel_free_deferred_event.test Test case 8: @mysql-test/suite/rpl/t/rpl_parallel_missed_error_handling.test Test case 9: @mysql-test/suite/rpl/t/rpl_parallel_innodb_lock_conflict.test Test case 10: @mysql-test/suite/rpl/t/rpl_parallel_gtid_slave_pos_update_fail.test Test case 11: @mysql-test/suite/rpl/t/rpl_parallel_wrong_exec_master_pos.test Test case 12: @mysql-test/suite/rpl/t/rpl_parallel_partial_binlog_trans.test Test case 13: @mysql-test/suite/rpl/t/rpl_parallel_ignore_error_on_rotate.test Test case 14: @mysql-test/suite/rpl/t/rpl_parallel_wrong_binlog_order.test Test case 15: @mysql-test/suite/rpl/t/rpl_parallel_incorrect_relay_pos.test Test case 16: @mysql-test/suite/rpl/t/rpl_parallel_retry_deadlock.test Test case 17: @mysql-test/suite/rpl/t/rpl_parallel_deadlock_corrupt_binlog.test Test case 18: @mysql-test/suite/rpl/t/rpl_parallel_mode.test Test case 19: @mysql-test/suite/rpl/t/rpl_parallel_analyze_table_hang.test Test case 20: @mysql-test/suite/rpl/t/rpl_parallel_record_gtid_wakeup.test Test case 21: @mysql-test/suite/rpl/t/rpl_parallel_stop_on_con_kill.test Test case 22: @mysql-test/suite/rpl/t/rpl_parallel_rollback_assert.test
342 lines
6.2 KiB
Text
342 lines
6.2 KiB
Text
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
|
|
SET @old_mode= @@GLOBAL.slave_parallel_mode;
|
|
SET GLOBAL slave_parallel_mode='conservative';
|
|
SET @old_threads= @@GLOBAL.slave_parallel_threads;
|
|
SET GLOBAL slave_parallel_threads=40;
|
|
SET @old_transaction_retries= @@GLOBAL.slave_transaction_retries;
|
|
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
|
|
*** 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;
|
|
SET GLOBAL slave_parallel_mode=@old_mode;
|
|
SET GLOBAL slave_parallel_threads=@old_threads;
|
|
SET GLOBAL slave_transaction_retries=@old_transaction_retries;
|
|
include/start_slave.inc
|
|
SET DEBUG_SYNC= 'RESET';
|
|
connection server_1;
|
|
DROP TABLE t7,t8;
|
|
SET DEBUG_SYNC= 'RESET';
|
|
include/rpl_end.inc
|