| Server IP : 104.21.38.3 / Your IP : 172.69.176.156 Web Server : Apache System : Linux krdc-ubuntu-s-2vcpu-4gb-amd-blr1-01.localdomain 5.15.0-142-generic #152-Ubuntu SMP Mon May 19 10:54:31 UTC 2025 x86_64 User : www ( 1000) PHP Version : 7.4.33 Disable Function : passthru,exec,system,putenv,chroot,chgrp,chown,shell_exec,popen,proc_open,pcntl_exec,ini_alter,ini_restore,dl,openlog,syslog,readlink,symlink,popepassthru,pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,imap_open,apache_setenv MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /www/server/mysql/src/mysql-test/suite/rpl/t/ |
Upload File : |
#
# The test verifies expected behaviour when
# the slave retries events starting from group internal position.
# Their execution in Logical_Clock mode is allowed.
# See bug#19473291.
# Notice that old master events are viewed effectively as
# malformed group events. Therefore this test applies to cross-version replication
# as well.
#
# GTIDs are expected in binlog when events are indexed by query_get_value below
--source include/have_gtid.inc
--source include/have_binlog_format_mixed.inc
--source include/master-slave.inc
# Logic of the test is as the following.
# Configure MTS with few workers and LOGICAL_CLOCK scheduler.
# Replicate some events.
# Stop slave threads to reconfigure retrival from an already read, executed and
# group internal position (COMMIT/Xid event position is chosen to avoid
# a GTID specific error).
# Restart slave threads and observe the SQL applier has processed events.
--source include/rpl_connection_slave.inc
call mtr.add_suppression("Either event.*is from an old master");
# The transaction boundary parser will log the following two warning messages:
call mtr.add_suppression("An unexpected event sequence was detected by the IO thread");
call mtr.add_suppression("QUERY.* is not expected in an event stream");
--source include/stop_slave.inc
SET @save_slave_parallel_type = @@GLOBAL.slave_parallel_type;
SET @save_slave_parallel_workers = @@GLOBAL.slave_parallel_workers;
SET @save_slave_transaction_retries = @@GLOBAL.slave_transaction_retries;
SET GLOBAL slave_parallel_type = LOGICAL_CLOCK;
SET GLOBAL slave_parallel_workers = 2;
SET GLOBAL slave_transaction_retries = 0;
--source include/start_slave.inc
--source include/rpl_connection_master.inc
CREATE TABLE t1(a INT);
INSERT INTO t1 SET a=1;
--let $binlog_file= query_get_value("SHOW MASTER STATUS", File, 1)
--let $logged_query= query_get_value(SHOW BINLOG EVENTS IN "$binlog_file" FROM 4, Info, 7)
--let $query_pos= query_get_value(SHOW BINLOG EVENTS IN "$binlog_file" FROM 4, End_log_pos,7)
--source include/sync_slave_sql_with_master.inc
--source include/stop_slave.inc
--replace_result $query_pos QUERY_POS
--eval CHANGE MASTER TO MASTER_LOG_POS=$query_pos, MASTER_AUTO_POSITION=0
--source include/start_slave_io.inc
START SLAVE SQL_THREAD;
#
# Cleanup
#
--source include/rpl_connection_master.inc
DROP TABLE t1;
--source include/sync_slave_sql_with_master.inc
--source include/stop_slave.inc
SET GLOBAL slave_parallel_workers = @save_slave_parallel_workers;
SET GLOBAL slave_parallel_type = @save_slave_parallel_type;
SET GLOBAL slave_transaction_retries = @save_slave_transaction_retries;
--source include/start_slave.inc
--source include/rpl_end.inc