mirror of
https://github.com/MariaDB/server.git
synced 2025-09-19 15:45:31 +02:00
0a68328673
This is actually an existing problem in the old binlog implementation, and this patch is applicable to old binlog also. The problem is that RESET MASTER can run concurrently with binlog dump threads / connected slaves. This will remove the binlog from under the feet of the reader, which can cause all sorts of strange behaviour. This patch fixes the problem by disallowing to run RESET MASTER when dump threads (or other RESET MASTER or SHOW BINARY LOGS) are running. An error is thrown in this case, user must stop slaves and/or kill dump threads to make the RESET MASTER go through. A slave that connects in the middle of RESET MASTER will wait for it to complete. Fix a lot of test cases to kill any lingering dump threads before doing RESET MASTER, mostly just by sourcing include/kill_binlog_dump_threads.inc. Signed-off-by: Kristian Nielsen <knielsen@knielsen-hq.org>
209 lines
6.6 KiB
Text
209 lines
6.6 KiB
Text
#
|
|
# This test creates 2x3 nodes galera cluster.
|
|
#
|
|
# A(1) <-> B(2) <-> C(3) {Galera cluster 1}
|
|
# | {Circular Async replication}
|
|
# D(4) <-> E(5) <-> F(6) {Galera cluster 2}
|
|
#
|
|
|
|
--source include/big_test.inc
|
|
--source include/galera_cluster.inc
|
|
--source include/have_innodb.inc
|
|
--source include/force_restart.inc
|
|
|
|
--connect node_6, 127.0.0.1, root, , test, $NODE_MYPORT_6
|
|
--connect node_5, 127.0.0.1, root, , test, $NODE_MYPORT_5
|
|
--connect node_4, 127.0.0.1, root, , test, $NODE_MYPORT_4
|
|
|
|
--connection node_4
|
|
|
|
--disable_query_log
|
|
--eval CHANGE MASTER TO master_host='127.0.0.1', master_user='root', MASTER_SSL_VERIFY_SERVER_CERT=0, master_port=$NODE_MYPORT_1, master_use_gtid=current_pos;
|
|
--enable_query_log
|
|
START SLAVE;
|
|
--source include/wait_for_slave_to_start.inc
|
|
|
|
#
|
|
# CREATE TABLE & INSERT
|
|
#
|
|
|
|
--connection node_1
|
|
|
|
CREATE TABLE t1(c1 INTEGER NOT NULL AUTO_INCREMENT PRIMARY KEY, c2 INTEGER);
|
|
INSERT INTO t1(c2) VALUES(1);
|
|
|
|
--connect node_3, 127.0.0.1, root, , test, $NODE_MYPORT_3
|
|
--connection node_3
|
|
|
|
SELECT COUNT(*) = 1 FROM t1;
|
|
|
|
--connection node_1
|
|
--source include/save_master_gtid.inc
|
|
|
|
--connection node_4
|
|
--source include/sync_with_master_gtid.inc
|
|
|
|
SELECT COUNT(*) = 1 FROM t1;
|
|
|
|
--connection node_6
|
|
|
|
SELECT COUNT(*) = 1 FROM t1;
|
|
|
|
#
|
|
# ALTER TABLE
|
|
#
|
|
|
|
--connection node_2
|
|
|
|
ALTER TABLE t1 ADD COLUMN t3 INTEGER;
|
|
--echo Node 2 column number AFTER ALTER
|
|
SELECT COUNT(*) = 3 FROM information_schema.columns WHERE table_name ='t1';
|
|
|
|
--connection node_3
|
|
|
|
--echo Node 3 column number AFTER ALTER
|
|
SELECT COUNT(*) = 3 FROM information_schema.columns WHERE table_name ='t1';
|
|
|
|
--connection node_1
|
|
--source include/save_master_gtid.inc
|
|
|
|
--connection node_4
|
|
--source include/sync_with_master_gtid.inc
|
|
|
|
--echo Node 4 column number AFTER ALTER
|
|
SELECT COUNT(*) = 3 FROM information_schema.columns WHERE table_name ='t1';
|
|
|
|
--connection node_6
|
|
|
|
--echo Node 6 column number AFTER ALTER
|
|
SELECT COUNT(*) = 3 FROM information_schema.columns WHERE table_name ='t1';
|
|
|
|
#
|
|
# OPTIMIZE TABLE
|
|
#
|
|
|
|
--connection node_2
|
|
--let $wsrep_last_committed_before_2 = `SELECT VARIABLE_VALUE FROM INFORMATION_SCHEMA.SESSION_STATUS WHERE VARIABLE_NAME = 'wsrep_last_committed'`
|
|
|
|
--connection node_1
|
|
--let $wsrep_last_committed_before_1 = `SELECT VARIABLE_VALUE FROM INFORMATION_SCHEMA.SESSION_STATUS WHERE VARIABLE_NAME = 'wsrep_last_committed'`
|
|
|
|
--connection node_3
|
|
--let $wsrep_last_committed_before_3 = `SELECT VARIABLE_VALUE FROM INFORMATION_SCHEMA.SESSION_STATUS WHERE VARIABLE_NAME = 'wsrep_last_committed'`
|
|
|
|
--connection node_4
|
|
--let $wsrep_last_committed_before_4 = `SELECT VARIABLE_VALUE FROM INFORMATION_SCHEMA.SESSION_STATUS WHERE VARIABLE_NAME = 'wsrep_last_committed'`
|
|
|
|
--connection node_5
|
|
--let $wsrep_last_committed_before_5 = `SELECT VARIABLE_VALUE FROM INFORMATION_SCHEMA.SESSION_STATUS WHERE VARIABLE_NAME = 'wsrep_last_committed'`
|
|
|
|
--connection node_6
|
|
--let $wsrep_last_committed_before_6 = `SELECT VARIABLE_VALUE FROM INFORMATION_SCHEMA.SESSION_STATUS WHERE VARIABLE_NAME = 'wsrep_last_committed'`
|
|
|
|
--connection node_2
|
|
OPTIMIZE TABLE t1;
|
|
--let $wait_condition = SELECT VARIABLE_VALUE >= $wsrep_last_committed_before_2 + 1 FROM INFORMATION_SCHEMA.SESSION_STATUS WHERE VARIABLE_NAME = 'wsrep_last_committed'
|
|
--source include/wait_condition.inc
|
|
|
|
--connection node_1
|
|
--let $wait_condition = SELECT VARIABLE_VALUE >= $wsrep_last_committed_before_1 + 1 FROM INFORMATION_SCHEMA.SESSION_STATUS WHERE VARIABLE_NAME = 'wsrep_last_committed'
|
|
--source include/wait_condition.inc
|
|
|
|
--connection node_3
|
|
--let $wait_condition = SELECT VARIABLE_VALUE >= $wsrep_last_committed_before_3 + 1 FROM INFORMATION_SCHEMA.SESSION_STATUS WHERE VARIABLE_NAME = 'wsrep_last_committed'
|
|
--source include/wait_condition.inc
|
|
|
|
--connection node_4
|
|
--let $wait_condition = SELECT VARIABLE_VALUE >= $wsrep_last_committed_before_4 + 1 FROM INFORMATION_SCHEMA.SESSION_STATUS WHERE VARIABLE_NAME = 'wsrep_last_committed'
|
|
--source include/wait_condition.inc
|
|
|
|
--connection node_5
|
|
--let $wait_condition = SELECT VARIABLE_VALUE >= $wsrep_last_committed_before_5 + 1 FROM INFORMATION_SCHEMA.SESSION_STATUS WHERE VARIABLE_NAME = 'wsrep_last_committed'
|
|
--source include/wait_condition.inc
|
|
|
|
--connection node_6
|
|
--let $wait_condition = SELECT VARIABLE_VALUE >= $wsrep_last_committed_before_6 + 1 FROM INFORMATION_SCHEMA.SESSION_STATUS WHERE VARIABLE_NAME = 'wsrep_last_committed'
|
|
--source include/wait_condition.inc
|
|
|
|
#
|
|
# Cleanup
|
|
#
|
|
|
|
--connection node_1
|
|
|
|
DROP TABLE t1;
|
|
|
|
--connection node_4
|
|
|
|
STOP SLAVE;
|
|
RESET SLAVE;
|
|
SET GLOBAL wsrep_on = OFF;
|
|
--source include/kill_binlog_dump_threads.inc
|
|
RESET MASTER;
|
|
SET GLOBAL wsrep_on = ON;
|
|
--source include/wait_until_ready.inc
|
|
SET GLOBAL GTID_SLAVE_POS="";
|
|
|
|
--connection node_1
|
|
|
|
SET GLOBAL wsrep_on = OFF;
|
|
--source include/kill_binlog_dump_threads.inc
|
|
RESET MASTER;
|
|
SET GLOBAL wsrep_on = ON;
|
|
--source include/wait_until_ready.inc
|
|
|
|
--connection node_2
|
|
|
|
SET GLOBAL wsrep_on = OFF;
|
|
--source include/kill_binlog_dump_threads.inc
|
|
RESET MASTER;
|
|
SET GLOBAL wsrep_on = ON;
|
|
--source include/wait_until_ready.inc
|
|
|
|
--connection node_3
|
|
|
|
SET GLOBAL wsrep_on = OFF;
|
|
--source include/kill_binlog_dump_threads.inc
|
|
RESET MASTER;
|
|
SET GLOBAL wsrep_on = ON;
|
|
--source include/wait_until_ready.inc
|
|
|
|
--connection node_5
|
|
|
|
SET GLOBAL wsrep_on = OFF;
|
|
--source include/kill_binlog_dump_threads.inc
|
|
RESET MASTER;
|
|
SET GLOBAL wsrep_on = ON;
|
|
--source include/wait_until_ready.inc
|
|
|
|
--connection node_6
|
|
|
|
SET GLOBAL wsrep_on = OFF;
|
|
--source include/kill_binlog_dump_threads.inc
|
|
RESET MASTER;
|
|
SET GLOBAL wsrep_on = ON;
|
|
--source include/wait_until_ready.inc
|
|
|
|
connection node_1;
|
|
CALL mtr.add_suppression("Ignoring server id .* for non bootstrap node");
|
|
CALL mtr.add_suppression("Unsafe statement written to the binary log using statement format since ");
|
|
|
|
connection node_2;
|
|
CALL mtr.add_suppression("Ignoring server id .* for non bootstrap node");
|
|
CALL mtr.add_suppression("Unsafe statement written to the binary log using statement format since ");
|
|
|
|
connection node_3;
|
|
CALL mtr.add_suppression("Ignoring server id .* for non bootstrap node");
|
|
CALL mtr.add_suppression("Unsafe statement written to the binary log using statement format since ");
|
|
|
|
connection node_4;
|
|
CALL mtr.add_suppression("Ignoring server id .* for non bootstrap node");
|
|
CALL mtr.add_suppression("Unsafe statement written to the binary log using statement format since ");
|
|
|
|
connection node_5;
|
|
CALL mtr.add_suppression("Ignoring server id .* for non bootstrap node");
|
|
CALL mtr.add_suppression("Unsafe statement written to the binary log using statement format since ");
|
|
|
|
connection node_6;
|
|
CALL mtr.add_suppression("Ignoring server id .* for non bootstrap node");
|
|
CALL mtr.add_suppression("Unsafe statement written to the binary log using statement format since ");
|