Skip to content

M
MariaDB
Commit ddc98339 authored by mkaruza's avatar mkaruza Committed by Jan Lindström
Browse files
Options

Fix for galera_3nodes.galera_gtid_2_cluster 

Temporary disable WSREP while executing RESET MASTER. In situation when 2 nodes are both master/slave first stop slave on both and than reset master.
Enforce stricter causality check with wsrep_sync_wait.
parent baed6632
Show whitespace changes
Inline Side-by-side
Showing with 129 additions and 6 deletions
mysql-test/suite/galera_3nodes/galera_2x3nodes.cnf
View file @ ddc98339
...@@ -13,8 +13,7 @@ gtid_ignore_duplicates ...@@ -13,8 +13,7 @@ gtid_ignore_duplicates
wsrep-provider=@ENV.WSREP_PROVIDER wsrep-provider=@ENV.WSREP_PROVIDER
wsrep_node_address=127.0.0.1 wsrep_node_address=127.0.0.1
# enforce read-committed characteristics across the cluster # enforce read-committed characteristics across the cluster
# wsrep-causal-reads=ON wsrep-sync-wait=15
# wsrep-sync-wait=15
[mysqld.1] [mysqld.1]
#galera_port=@OPT.port #galera_port=@OPT.port
......
mysql-test/suite/galera_3nodes/r/galera_gtid_2_cluster.result
View file @ ddc98339
connection node_2;
connection node_1;
connection node_1;
cluster 1 node 1 cluster 1 node 1
SHOW STATUS LIKE 'wsrep_cluster_size'; SHOW STATUS LIKE 'wsrep_cluster_size';
Variable_name Value Variable_name Value
wsrep_cluster_size 3 wsrep_cluster_size 3
connection node_2;
cluster 1 node 2 cluster 1 node 2
SHOW STATUS LIKE 'wsrep_cluster_size'; SHOW STATUS LIKE 'wsrep_cluster_size';
Variable_name Value Variable_name Value
wsrep_cluster_size 3 wsrep_cluster_size 3
connect node_3, 127.0.0.1, root, , test, $NODE_MYPORT_3;
connection node_3;
cluster 1 node 3 cluster 1 node 3
SHOW STATUS LIKE 'wsrep_cluster_size'; SHOW STATUS LIKE 'wsrep_cluster_size';
Variable_name Value Variable_name Value
wsrep_cluster_size 3 wsrep_cluster_size 3
connect node_4, 127.0.0.1, root, , test, $NODE_MYPORT_4;
connection node_4;
cluster 2 node 1 cluster 2 node 1
SHOW STATUS LIKE 'wsrep_cluster_size'; SHOW STATUS LIKE 'wsrep_cluster_size';
Variable_name Value Variable_name Value
wsrep_cluster_size 3 wsrep_cluster_size 3
connect node_5, 127.0.0.1, root, , test, $NODE_MYPORT_5;
connection node_5;
cluster 2 node 2 cluster 2 node 2
SHOW STATUS LIKE 'wsrep_cluster_size'; SHOW STATUS LIKE 'wsrep_cluster_size';
Variable_name Value Variable_name Value
wsrep_cluster_size 3 wsrep_cluster_size 3
connect node_6, 127.0.0.1, root, , test, $NODE_MYPORT_6;
connection node_6;
cluster 2 node 3 cluster 2 node 3
SHOW STATUS LIKE 'wsrep_cluster_size'; SHOW STATUS LIKE 'wsrep_cluster_size';
Variable_name Value Variable_name Value
wsrep_cluster_size 3 wsrep_cluster_size 3
connection node_1;
change master to master_host='127.0.0.1', master_user='root', master_port=NODE_MYPORT_4, master_use_gtid=current_pos, ignore_server_ids=(12,13);; change master to master_host='127.0.0.1', master_user='root', master_port=NODE_MYPORT_4, master_use_gtid=current_pos, ignore_server_ids=(12,13);;
start slave; start slave;
include/wait_for_slave_to_start.inc include/wait_for_slave_to_start.inc
...@@ -31,6 +44,7 @@ select @@gtid_binlog_state; ...@@ -31,6 +44,7 @@ select @@gtid_binlog_state;
select @@gtid_slave_pos; select @@gtid_slave_pos;
@@gtid_slave_pos @@gtid_slave_pos
connection node_4;
change master to master_host='127.0.0.1', master_user='root', master_port=NODE_MYPORT_1, master_use_gtid=current_pos, ignore_server_ids=(22,23);; change master to master_host='127.0.0.1', master_user='root', master_port=NODE_MYPORT_1, master_use_gtid=current_pos, ignore_server_ids=(22,23);;
start slave; start slave;
include/wait_for_slave_to_start.inc include/wait_for_slave_to_start.inc
...@@ -41,15 +55,19 @@ select @@gtid_slave_pos; ...@@ -41,15 +55,19 @@ select @@gtid_slave_pos;
@@gtid_slave_pos @@gtid_slave_pos
cluster 1 node 1 cluster 1 node 1
connection node_1;
create table t1 (cluster_domain_id int ,node_server_id int, seq_no int); create table t1 (cluster_domain_id int ,node_server_id int, seq_no int);
insert into t1 values (1, 11, 2); insert into t1 values (1, 11, 2);
select @@gtid_binlog_state; select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-11-2 1-11-2
#wait for sync cluster 1 and 2 #wait for sync cluster 1 and 2
connection node_1;
include/save_master_gtid.inc include/save_master_gtid.inc
connection node_4;
include/sync_with_master_gtid.inc include/sync_with_master_gtid.inc
cluster 2 node 1 cluster 2 node 1
connection node_4;
select @@gtid_binlog_state; select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-11-2 1-11-2
...@@ -62,9 +80,12 @@ cluster_domain_id node_server_id seq_no ...@@ -62,9 +80,12 @@ cluster_domain_id node_server_id seq_no
1 11 2 1 11 2
2 21 1 2 21 1
#wait for sync cluster 1 and 2 #wait for sync cluster 1 and 2
connection node_1;
include/save_master_gtid.inc include/save_master_gtid.inc
connection node_4;
include/sync_with_master_gtid.inc include/sync_with_master_gtid.inc
cluster 1 node 2 cluster 1 node 2
connection node_2;
select @@gtid_binlog_state; select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-11-2,2-21-1 1-11-2,2-21-1
...@@ -73,9 +94,12 @@ select @@gtid_binlog_state; ...@@ -73,9 +94,12 @@ select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-11-2,1-12-3,2-21-1 1-11-2,1-12-3,2-21-1
#wait for sync cluster 1 and 2 #wait for sync cluster 1 and 2
connection node_1;
include/save_master_gtid.inc include/save_master_gtid.inc
connection node_4;
include/sync_with_master_gtid.inc include/sync_with_master_gtid.inc
cluster 1 node 3 cluster 1 node 3
connection node_3;
select @@gtid_binlog_state; select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-11-2,1-12-3,2-21-1 1-11-2,1-12-3,2-21-1
...@@ -84,9 +108,12 @@ select @@gtid_binlog_state; ...@@ -84,9 +108,12 @@ select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-12-3,1-11-2,1-13-4,2-21-1 1-12-3,1-11-2,1-13-4,2-21-1
#wait for sync cluster 1 and 2 #wait for sync cluster 1 and 2
connection node_1;
include/save_master_gtid.inc include/save_master_gtid.inc
connection node_4;
include/sync_with_master_gtid.inc include/sync_with_master_gtid.inc
cluster 2 node 2 cluster 2 node 2
connection node_5;
select @@gtid_binlog_state; select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-12-3,1-11-2,1-13-4,2-21-1 1-12-3,1-11-2,1-13-4,2-21-1
...@@ -95,9 +122,12 @@ select @@gtid_binlog_state; ...@@ -95,9 +122,12 @@ select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-12-3,1-11-2,1-13-4,2-21-1,2-22-2 1-12-3,1-11-2,1-13-4,2-21-1,2-22-2
#wait for sync cluster 2 and 1 #wait for sync cluster 2 and 1
connection node_4;
include/save_master_gtid.inc include/save_master_gtid.inc
connection node_1;
include/sync_with_master_gtid.inc include/sync_with_master_gtid.inc
cluster 2 node 3 cluster 2 node 3
connection node_6;
select @@gtid_binlog_state; select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-12-3,1-11-2,1-13-4,2-21-1,2-22-2 1-12-3,1-11-2,1-13-4,2-21-1,2-22-2
...@@ -106,28 +136,53 @@ select @@gtid_binlog_state; ...@@ -106,28 +136,53 @@ select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-12-3,1-11-2,1-13-4,2-21-1,2-22-2,2-23-3 1-12-3,1-11-2,1-13-4,2-21-1,2-22-2,2-23-3
#wait for sync cluster 2 and 1 #wait for sync cluster 2 and 1
connection node_4;
include/save_master_gtid.inc include/save_master_gtid.inc
connection node_1;
include/sync_with_master_gtid.inc include/sync_with_master_gtid.inc
cluster 1 node 1 cluster 1 node 1
connection node_1;
select @@gtid_binlog_state; select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-12-3,1-11-2,1-13-4,2-21-1,2-22-2,2-23-3 1-12-3,1-11-2,1-13-4,2-21-1,2-22-2,2-23-3
drop table t1; drop table t1;
stop slave; stop slave;
reset slave; reset slave;
cluster 2 node 1
connection node_4;
stop slave;
reset slave;
cluster 1 node 1
connection node_1;
change master to master_use_gtid=no, ignore_server_ids=(); change master to master_use_gtid=no, ignore_server_ids=();
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
set global GTID_SLAVE_POS=""; set global GTID_SLAVE_POS="";
cluster 2 node 1 cluster 2 node 1
stop slave; connection node_4;
reset slave;
change master to master_use_gtid=no, ignore_server_ids=(); change master to master_use_gtid=no, ignore_server_ids=();
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
set global GTID_SLAVE_POS=""; set global GTID_SLAVE_POS="";
connection node_2;
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
connection node_3;
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
connection node_5;
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
connection node_6;
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
connection node_1;
change master to master_host='127.0.0.1', master_user='root', master_port=NODE_MYPORT_6, master_use_gtid=current_pos, ignore_server_ids=(12,13);; change master to master_host='127.0.0.1', master_user='root', master_port=NODE_MYPORT_6, master_use_gtid=current_pos, ignore_server_ids=(12,13);;
start slave; start slave;
include/wait_for_slave_to_start.inc include/wait_for_slave_to_start.inc
...@@ -137,6 +192,7 @@ select @@gtid_binlog_state; ...@@ -137,6 +192,7 @@ select @@gtid_binlog_state;
select @@gtid_slave_pos; select @@gtid_slave_pos;
@@gtid_slave_pos @@gtid_slave_pos
connection node_4;
change master to master_host='127.0.0.1', master_user='root', master_port=NODE_MYPORT_3, master_use_gtid=current_pos, ignore_server_ids=(22,23);; change master to master_host='127.0.0.1', master_user='root', master_port=NODE_MYPORT_3, master_use_gtid=current_pos, ignore_server_ids=(22,23);;
start slave; start slave;
include/wait_for_slave_to_start.inc include/wait_for_slave_to_start.inc
...@@ -147,15 +203,19 @@ select @@gtid_slave_pos; ...@@ -147,15 +203,19 @@ select @@gtid_slave_pos;
@@gtid_slave_pos @@gtid_slave_pos
cluster 1 node 1 cluster 1 node 1
connection node_1;
create table t1 (cluster_domain_id int ,node_server_id int, seq_no int); create table t1 (cluster_domain_id int ,node_server_id int, seq_no int);
insert into t1 values (1, 11, 2); insert into t1 values (1, 11, 2);
select @@gtid_binlog_state; select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-11-2 1-11-2
#wait for sync cluster 1 and 2 #wait for sync cluster 1 and 2
connection node_1;
include/save_master_gtid.inc include/save_master_gtid.inc
connection node_4;
include/sync_with_master_gtid.inc include/sync_with_master_gtid.inc
cluster 2 node 1 cluster 2 node 1
connection node_4;
insert into t1 values (2, 21, 1); insert into t1 values (2, 21, 1);
select @@gtid_binlog_state; select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
...@@ -165,9 +225,12 @@ cluster_domain_id node_server_id seq_no ...@@ -165,9 +225,12 @@ cluster_domain_id node_server_id seq_no
1 11 2 1 11 2
2 21 1 2 21 1
#wait for sync cluster 1 and 2 #wait for sync cluster 1 and 2
connection node_1;
include/save_master_gtid.inc include/save_master_gtid.inc
connection node_4;
include/sync_with_master_gtid.inc include/sync_with_master_gtid.inc
cluster 1 node 2 cluster 1 node 2
connection node_2;
select @@gtid_binlog_state; select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-11-2,2-21-1 1-11-2,2-21-1
...@@ -176,9 +239,12 @@ select @@gtid_binlog_state; ...@@ -176,9 +239,12 @@ select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-11-2,1-12-3,2-21-1 1-11-2,1-12-3,2-21-1
#wait for sync cluster 1 and 2 #wait for sync cluster 1 and 2
connection node_1;
include/save_master_gtid.inc include/save_master_gtid.inc
connection node_4;
include/sync_with_master_gtid.inc include/sync_with_master_gtid.inc
cluster 1 node 3 cluster 1 node 3
connection node_3;
select @@gtid_binlog_state; select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-11-2,1-12-3,2-21-1 1-11-2,1-12-3,2-21-1
...@@ -187,9 +253,12 @@ select @@gtid_binlog_state; ...@@ -187,9 +253,12 @@ select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-12-3,1-11-2,1-13-4,2-21-1 1-12-3,1-11-2,1-13-4,2-21-1
#wait for sync cluster 1 and 2 #wait for sync cluster 1 and 2
connection node_1;
include/save_master_gtid.inc include/save_master_gtid.inc
connection node_4;
include/sync_with_master_gtid.inc include/sync_with_master_gtid.inc
cluster 2 node 2 cluster 2 node 2
connection node_5;
select @@gtid_binlog_state; select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-12-3,1-11-2,1-13-4,2-21-1 1-12-3,1-11-2,1-13-4,2-21-1
...@@ -198,9 +267,12 @@ select @@gtid_binlog_state; ...@@ -198,9 +267,12 @@ select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-12-3,1-11-2,1-13-4,2-21-1,2-22-2 1-12-3,1-11-2,1-13-4,2-21-1,2-22-2
#wait for sync cluster 2 and 1 #wait for sync cluster 2 and 1
connection node_4;
include/save_master_gtid.inc include/save_master_gtid.inc
connection node_1;
include/sync_with_master_gtid.inc include/sync_with_master_gtid.inc
cluster 2 node 3 cluster 2 node 3
connection node_6;
select @@gtid_binlog_state; select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-12-3,1-11-2,1-13-4,2-21-1,2-22-2 1-12-3,1-11-2,1-13-4,2-21-1,2-22-2
...@@ -209,23 +281,43 @@ select @@gtid_binlog_state; ...@@ -209,23 +281,43 @@ select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-12-3,1-11-2,1-13-4,2-21-1,2-22-2,2-23-3 1-12-3,1-11-2,1-13-4,2-21-1,2-22-2,2-23-3
#wait for sync cluster 2 and 1 #wait for sync cluster 2 and 1
connection node_4;
include/save_master_gtid.inc include/save_master_gtid.inc
connection node_1;
include/sync_with_master_gtid.inc include/sync_with_master_gtid.inc
cluster 1 node 1 cluster 1 node 1
connection node_1;
select @@gtid_binlog_state; select @@gtid_binlog_state;
@@gtid_binlog_state @@gtid_binlog_state
1-12-3,1-11-2,1-13-4,2-21-1,2-22-2,2-23-3 1-12-3,1-11-2,1-13-4,2-21-1,2-22-2,2-23-3
drop table t1; drop table t1;
stop slave; stop slave;
change master to master_use_gtid=no, ignore_server_ids=(); change master to master_use_gtid=no, ignore_server_ids=();
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
set global GTID_SLAVE_POS=""; set global GTID_SLAVE_POS="";
cluster 2 node 1 cluster 2 node 1
connection node_4;
stop slave; stop slave;
change master to master_use_gtid=no, ignore_server_ids=(); change master to master_use_gtid=no, ignore_server_ids=();
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
set global GTID_SLAVE_POS=""; set global GTID_SLAVE_POS="";
connection node_2;
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
connection node_3;
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
connection node_5;
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
connection node_6;
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
mysql-test/suite/galera_3nodes/t/galera_gtid_2_cluster.test
View file @ ddc98339
...@@ -138,27 +138,45 @@ select @@gtid_binlog_state; ...@@ -138,27 +138,45 @@ select @@gtid_binlog_state;
drop table t1; drop table t1;
stop slave; stop slave;
reset slave; reset slave;
--echo cluster 2 node 1
--connection node_4
stop slave;
reset slave;
--echo cluster 1 node 1
--connection node_1
change master to master_use_gtid=no, ignore_server_ids=(); change master to master_use_gtid=no, ignore_server_ids=();
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
set global GTID_SLAVE_POS=""; set global GTID_SLAVE_POS="";
--sleep 2 --sleep 2
--echo cluster 2 node 1 --echo cluster 2 node 1
--connection node_4 --connection node_4
stop slave;
reset slave;
change master to master_use_gtid=no, ignore_server_ids=(); change master to master_use_gtid=no, ignore_server_ids=();
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
set global GTID_SLAVE_POS=""; set global GTID_SLAVE_POS="";
--connection node_2 --connection node_2
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
--connection node_3 --connection node_3
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
--connection node_5 --connection node_5
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
--connection node_6 --connection node_6
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
#--enable_parsing #--enable_parsing
# #
# This test creates 2x 3 nodes galera cluster. # This test creates 2x 3 nodes galera cluster.
...@@ -272,21 +290,33 @@ select @@gtid_binlog_state; ...@@ -272,21 +290,33 @@ select @@gtid_binlog_state;
drop table t1; drop table t1;
stop slave; stop slave;
change master to master_use_gtid=no, ignore_server_ids=(); change master to master_use_gtid=no, ignore_server_ids=();
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
set global GTID_SLAVE_POS=""; set global GTID_SLAVE_POS="";
--echo cluster 2 node 1 --echo cluster 2 node 1
--connection node_4 --connection node_4
stop slave; stop slave;
change master to master_use_gtid=no, ignore_server_ids=(); change master to master_use_gtid=no, ignore_server_ids=();
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
set global GTID_SLAVE_POS=""; set global GTID_SLAVE_POS="";
--connection node_2 --connection node_2
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
--connection node_3 --connection node_3
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
--connection node_5 --connection node_5
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
--connection node_6 --connection node_6
set global wsrep_on=OFF;
reset master; reset master;
set global wsrep_on=ON;
sql/sql_repl.cc
View file @ ddc98339
...@@ -3369,6 +3369,7 @@ static my_bool kill_callback(THD *thd, kill_callback_arg *arg) ...@@ -3369,6 +3369,7 @@ static my_bool kill_callback(THD *thd, kill_callback_arg *arg)
thd->variables.server_id == arg->slave_server_id) thd->variables.server_id == arg->slave_server_id)
{ {
arg->thd= thd; arg->thd= thd;
if (WSREP(thd)) mysql_mutex_lock(&thd->LOCK_thd_data);
mysql_mutex_lock(&thd->LOCK_thd_kill); // Lock from delete mysql_mutex_lock(&thd->LOCK_thd_kill); // Lock from delete
return 1; return 1;
} }
...@@ -3390,6 +3391,7 @@ void kill_zombie_dump_threads(uint32 slave_server_id) ...@@ -3390,6 +3391,7 @@ void kill_zombie_dump_threads(uint32 slave_server_id)
*/ */
arg.thd->awake_no_mutex(KILL_SLAVE_SAME_ID); arg.thd->awake_no_mutex(KILL_SLAVE_SAME_ID);
mysql_mutex_unlock(&arg.thd->LOCK_thd_kill); mysql_mutex_unlock(&arg.thd->LOCK_thd_kill);
if (WSREP(arg.thd)) mysql_mutex_unlock(&arg.thd->LOCK_thd_data);
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment
GitLab Nexedi Edition | About GitLab | About Nexedi | 沪ICP备2021021310号-2 | 沪ICP备2021021310号-7