Commit a4b6409f authored by Sergei Golubchik's avatar Sergei Golubchik

sporadic failures of binlog_encryption.rpl_parallel_slave_bgc_kill

do CHANGE MASTER before sync_with_master to have the slave
in a predictable fully synced state before the next test
parent c7c39671
...@@ -206,10 +206,12 @@ RETURN x; ...@@ -206,10 +206,12 @@ RETURN x;
END END
|| ||
SET sql_log_bin=1; SET sql_log_bin=1;
include/stop_slave_io.inc
connection server_1; connection server_1;
INSERT INTO t3 VALUES (49,0); INSERT INTO t3 VALUES (49,0);
connection server_2; connection server_2;
START SLAVE SQL_THREAD; CHANGE MASTER TO master_use_gtid=no;
include/start_slave.inc
SELECT * FROM t3 WHERE a >= 40 ORDER BY a; SELECT * FROM t3 WHERE a >= 40 ORDER BY a;
a b a b
41 41 41 41
...@@ -239,10 +241,6 @@ SET GLOBAL slave_parallel_threads=0; ...@@ -239,10 +241,6 @@ SET GLOBAL slave_parallel_threads=0;
SET GLOBAL slave_parallel_threads=10; SET GLOBAL slave_parallel_threads=10;
include/start_slave.inc include/start_slave.inc
*** 3. Same as (2), but not using gtid mode *** *** 3. Same as (2), but not using gtid mode ***
connection server_2;
include/stop_slave.inc
CHANGE MASTER TO master_use_gtid=no;
include/start_slave.inc
connection server_1; connection server_1;
connection con_temp3; connection con_temp3;
SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued1 WAIT_FOR master_cont1'; SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued1 WAIT_FOR master_cont1';
......
...@@ -206,10 +206,12 @@ RETURN x; ...@@ -206,10 +206,12 @@ RETURN x;
END END
|| ||
SET sql_log_bin=1; SET sql_log_bin=1;
include/stop_slave_io.inc
connection server_1; connection server_1;
INSERT INTO t3 VALUES (49,0); INSERT INTO t3 VALUES (49,0);
connection server_2; connection server_2;
START SLAVE SQL_THREAD; CHANGE MASTER TO master_use_gtid=no;
include/start_slave.inc
SELECT * FROM t3 WHERE a >= 40 ORDER BY a; SELECT * FROM t3 WHERE a >= 40 ORDER BY a;
a b a b
41 41 41 41
...@@ -239,10 +241,6 @@ SET GLOBAL slave_parallel_threads=0; ...@@ -239,10 +241,6 @@ SET GLOBAL slave_parallel_threads=0;
SET GLOBAL slave_parallel_threads=10; SET GLOBAL slave_parallel_threads=10;
include/start_slave.inc include/start_slave.inc
*** 3. Same as (2), but not using gtid mode *** *** 3. Same as (2), but not using gtid mode ***
connection server_2;
include/stop_slave.inc
CHANGE MASTER TO master_use_gtid=no;
include/start_slave.inc
connection server_1; connection server_1;
connection con_temp3; connection con_temp3;
SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued1 WAIT_FOR master_cont1'; SET debug_sync='commit_after_release_LOCK_prepare_ordered SIGNAL master_queued1 WAIT_FOR master_cont1';
......
...@@ -295,13 +295,14 @@ CREATE FUNCTION foo(x INT, d1 VARCHAR(500), d2 VARCHAR(500)) ...@@ -295,13 +295,14 @@ CREATE FUNCTION foo(x INT, d1 VARCHAR(500), d2 VARCHAR(500))
|| ||
--delimiter ; --delimiter ;
SET sql_log_bin=1; SET sql_log_bin=1;
--source include/stop_slave_io.inc
--connection server_1 --connection server_1
INSERT INTO t3 VALUES (49,0); INSERT INTO t3 VALUES (49,0);
--save_master_pos --save_master_pos
--connection server_2 --connection server_2
START SLAVE SQL_THREAD; CHANGE MASTER TO master_use_gtid=no;
--source include/start_slave.inc
--sync_with_master --sync_with_master
SELECT * FROM t3 WHERE a >= 40 ORDER BY a; SELECT * FROM t3 WHERE a >= 40 ORDER BY a;
# Restore the foo() function. # Restore the foo() function.
...@@ -334,11 +335,6 @@ SET GLOBAL slave_parallel_threads=10; ...@@ -334,11 +335,6 @@ SET GLOBAL slave_parallel_threads=10;
--echo *** 3. Same as (2), but not using gtid mode *** --echo *** 3. Same as (2), but not using gtid mode ***
--connection server_2
--source include/stop_slave.inc
CHANGE MASTER TO master_use_gtid=no;
--source include/start_slave.inc
--connection server_1 --connection server_1
# Set up three transactions on the master that will be group-committed # Set up three transactions on the master that will be group-committed
# together so they can be replicated in parallel on the slave. # together so they can be replicated in parallel on the slave.
......
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