1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
|
include/master-slave.inc
Warnings:
Note #### Sending passwords in plain text without SSL/TLS is extremely insecure.
Note #### Storing MySQL user name or password information in the connection metadata repository is not secure and is therefore not recommended. Please consider using the USER and PASSWORD connection options for START REPLICA; see the 'START REPLICA Syntax' in the MySQL Manual for more information.
[connection master]
call mtr.add_suppression("Replica SQL for channel '': .*Could not execute Write_rows event on table d1.t1; Duplicate entry '13' for key .*");
call mtr.add_suppression("Replica SQL for channel '': ... The replica coordinator and worker threads are stopped, possibly leaving data in inconsistent state.");
call mtr.add_suppression("Error writing relay log configuration.");
include/stop_slave.inc
SET @save.replica_parallel_workers=@@global.replica_parallel_workers;
SET @@global.replica_parallel_workers=2;
include/start_slave.inc
CREATE DATABASE d1;
CREATE DATABASE d2;
CREATE TABLE d1.t1 (a int unique) ENGINE=INNODB;
CREATE TABLE d2.t1 (a int unique) ENGINE=INNODB;
INSERT INTO d1.t1 VALUES (1);
FLUSH LOGS;
include/sync_slave_sql_with_master.inc
include/stop_slave.inc
CHANGE REPLICATION SOURCE TO SOURCE_DELAY=5;
include/start_slave.inc
INSERT INTO d1.t1 VALUES (3);
INSERT INTO d1.t1 VALUES (5);
FLUSH LOGS;
include/stop_slave.inc
CHANGE REPLICATION SOURCE TO RELAY_LOG_FILE=FILE, RELAY_LOG_POS= POS;
include/start_slave.inc
include/stop_slave.inc
CHANGE REPLICATION SOURCE TO RELAY_LOG_FILE=FILE, RELAY_LOG_POS= POS, SOURCE_DELAY=0;
include/start_slave.inc
BEGIN;
INSERT INTO d1.t1 VALUES (13);
INSERT INTO d1.t1 VALUES (6);
INSERT INTO d2.t1 VALUES (7);
BEGIN;
INSERT INTO d1.t1 VALUES (13);
BEGIN;
INSERT INTO d2.t1 VALUES (8);
COMMIT;
COMMIT;
INSERT INTO d2.t1 VALUES (9);
COMMIT;
include/wait_for_slave_sql_error.inc [errno=1062]
include/stop_slave_io.inc
CHANGE REPLICATION SOURCE TO RELAY_LOG_FILE=FILE, RELAY_LOG_POS= POS;
ERROR HY000: CHANGE REPLICATION SOURCE cannot be executed when the replica was stopped with an error or killed in MTA mode. Consider using RESET REPLICA or START REPLICA UNTIL.
SET @@global.replica_parallel_workers= @save.replica_parallel_workers;
include/rpl_restart_server.inc [server_number=2 parameters: --relay-log-recovery --skip-replica-start]
SELECT @@global.relay_log_recovery as 'must be ON';
must be ON
1
call mtr.add_suppression("MTA recovery: automatic recovery failed.*");
call mtr.add_suppression("Failed to initialize the connection metadata structure");
call mtr.add_suppression("Failed to create or recover replication info repositories.");
call mtr.add_suppression("It is not possible to change the type of the relay log repository because there are workers repositories with possible execution gaps. The value of --relay_log_info_repository is altered to one of the found Worker repositories");
include/rpl_restart_server.inc [server_number=2 parameters: --skip-replica-start]
SELECT @@global.relay_log_recovery as 'must be OFF';
must be OFF
0
DELETE FROM d1.t1 WHERE a = 13;
include/start_slave.inc
DROP DATABASE d1;
DROP DATABASE d2;
include/sync_slave_sql_with_master.inc
[connection slave]
include/stop_slave.inc
SET @save.replica_parallel_workers=@@global.replica_parallel_workers;
SET @@global.replica_parallel_workers=2;
SET @save.relay_log_info_repository=@@global.relay_log_info_repository;
Warnings:
Warning 1287 '@@relay_log_info_repository' is deprecated and will be removed in a future release.
SET @@global.relay_log_info_repository='TABLE';
Warnings:
Warning 1287 '@@relay_log_info_repository' is deprecated and will be removed in a future release.
include/start_slave.inc
[connection master]
CREATE DATABASE d1;
CREATE DATABASE d2;
CREATE TABLE d1.t1 (a int unique) ENGINE=INNODB;
CREATE TABLE d2.t1 (a int unique) ENGINE=INNODB;
include/sync_slave_sql_with_master.inc
BEGIN;
INSERT INTO d1.t1 VALUES (13);
[connection master]
INSERT INTO d1.t1 VALUES (6);
INSERT INTO d2.t1 VALUES (7);
BEGIN;
INSERT INTO d1.t1 VALUES (13);
BEGIN;
INSERT INTO d2.t1 VALUES (8);
COMMIT;
COMMIT;
INSERT INTO d2.t1 VALUES (9);
[connection slave1]
[connection slave]
COMMIT;
include/wait_for_slave_sql_error.inc [errno=1062]
include/stop_slave_io.inc
[connection master]
FLUSH LOGS;
[connection slave]
CHANGE REPLICATION SOURCE TO SOURCE_HOST= '127.0.0.1', SOURCE_PORT= MASTER_PORT, SOURCE_USER= 'root',SOURCE_LOG_FILE = 'FILE', SOURCE_LOG_POS = POS ;
ERROR HY000: CHANGE REPLICATION SOURCE cannot be executed when the replica was stopped with an error or killed in MTA mode. Consider using RESET REPLICA or START REPLICA UNTIL.
reset slave;
Warnings:
Warning 1287 'RESET SLAVE' is deprecated and will be removed in a future release. Please use RESET REPLICA instead
CHANGE REPLICATION SOURCE TO SOURCE_HOST= '127.0.0.1', SOURCE_PORT= MASTER_PORT, SOURCE_USER= 'root',SOURCE_LOG_FILE = 'FILE', SOURCE_LOG_POS = POS ;
Warnings:
Note #### Sending passwords in plain text without SSL/TLS is extremely insecure.
Note #### Storing MySQL user name or password information in the connection metadata repository is not secure and is therefore not recommended. Please consider using the USER and PASSWORD connection options for START REPLICA; see the 'START REPLICA Syntax' in the MySQL Manual for more information.
SET @@global.replica_parallel_workers= @save.replica_parallel_workers;
SET @@global.relay_log_info_repository= @save.relay_log_info_repository;
include/start_slave.inc
[connection master]
DROP DATABASE d1;
DROP DATABASE d2;
include/rpl_end.inc
|
