mirror of
https://github.com/MariaDB/server.git
synced 2025-08-07 00:04:31 +03:00
Automerge from bug branch.
This commit is contained in:
@@ -10,47 +10,7 @@ insert into t1(b) values (1);
|
|||||||
insert into t1(b) values (2);
|
insert into t1(b) values (2);
|
||||||
load data infile '../../std_data/rpl_loaddata.dat' into table t1;
|
load data infile '../../std_data/rpl_loaddata.dat' into table t1;
|
||||||
commit;
|
commit;
|
||||||
show slave status;
|
|
||||||
Slave_IO_State #
|
|
||||||
Master_Host 127.0.0.1
|
|
||||||
Master_User root
|
|
||||||
Master_Port MASTER_MYPORT
|
|
||||||
Connect_Retry 1
|
|
||||||
Master_Log_File master-bin.000001
|
|
||||||
Read_Master_Log_Pos #
|
|
||||||
Relay_Log_File #
|
|
||||||
Relay_Log_Pos #
|
|
||||||
Relay_Master_Log_File master-bin.000001
|
|
||||||
Slave_IO_Running Yes
|
|
||||||
Slave_SQL_Running No
|
|
||||||
Replicate_Do_DB
|
|
||||||
Replicate_Ignore_DB
|
|
||||||
Replicate_Do_Table
|
|
||||||
Replicate_Ignore_Table
|
|
||||||
Replicate_Wild_Do_Table
|
|
||||||
Replicate_Wild_Ignore_Table
|
|
||||||
Last_Errno 9
|
|
||||||
Last_Error Error in Begin_load_query event: write to '../../tmp/SQL_LOAD.data' failed
|
|
||||||
Skip_Counter 0
|
|
||||||
Exec_Master_Log_Pos #
|
|
||||||
Relay_Log_Space #
|
|
||||||
Until_Condition None
|
|
||||||
Until_Log_File
|
|
||||||
Until_Log_Pos 0
|
|
||||||
Master_SSL_Allowed No
|
|
||||||
Master_SSL_CA_File
|
|
||||||
Master_SSL_CA_Path
|
|
||||||
Master_SSL_Cert
|
|
||||||
Master_SSL_Cipher
|
|
||||||
Master_SSL_Key
|
|
||||||
Seconds_Behind_Master #
|
|
||||||
Master_SSL_Verify_Server_Cert No
|
|
||||||
Last_IO_Errno #
|
|
||||||
Last_IO_Error #
|
|
||||||
Last_SQL_Errno 9
|
|
||||||
Last_SQL_Error Error in Begin_load_query event: write to '../../tmp/SQL_LOAD.data' failed
|
|
||||||
Replicate_Ignore_Server_Ids
|
|
||||||
Master_Server_Id 1
|
|
||||||
drop table t1;
|
drop table t1;
|
||||||
drop table t1;
|
drop table t1;
|
||||||
call mtr.add_suppression("Slave: Error writing file 'UNKNOWN' .Errcode: 9. Error_code: 3");
|
call mtr.add_suppression("Slave: Can't get stat of .*");
|
||||||
|
call mtr.add_suppression("Slave: File.* not found.*");
|
||||||
|
@@ -33,10 +33,17 @@ commit;
|
|||||||
connection slave;
|
connection slave;
|
||||||
source include/wait_for_slave_sql_to_stop.inc;
|
source include/wait_for_slave_sql_to_stop.inc;
|
||||||
|
|
||||||
--replace_result $MASTER_MYPORT MASTER_MYPORT
|
--let $error= query_get_value(SHOW SLAVE STATUS, Last_Errno, 1)
|
||||||
--replace_column 1 # 7 # 8 # 9 # 22 # 23 # 33 # 35 # 36 #
|
# windows and linux different error numbers here:
|
||||||
--replace_regex /SQL_LOAD-[0-9]-[0-9]-[0-9]*/SQL_LOAD/
|
# Windows:
|
||||||
query_vertical show slave status;
|
# - Last_Errno 29 (File not found)
|
||||||
|
# Unix like OS:
|
||||||
|
# - Last_Errno 13 (Can't stat file)
|
||||||
|
--let $assertion= `SELECT $error=29 OR $error=13`
|
||||||
|
if (!$assertion)
|
||||||
|
{
|
||||||
|
--echo UNEXPECTED ERROR NUMBER: $error
|
||||||
|
}
|
||||||
|
|
||||||
##########################################################################
|
##########################################################################
|
||||||
# Clean up
|
# Clean up
|
||||||
@@ -49,4 +56,5 @@ connection slave;
|
|||||||
|
|
||||||
drop table t1;
|
drop table t1;
|
||||||
|
|
||||||
call mtr.add_suppression("Slave: Error writing file 'UNKNOWN' .Errcode: 9. Error_code: 3");
|
call mtr.add_suppression("Slave: Can't get stat of .*");
|
||||||
|
call mtr.add_suppression("Slave: File.* not found.*");
|
||||||
|
@@ -64,8 +64,15 @@ stop slave IO_THREAD;
|
|||||||
source include/wait_for_slave_io_to_stop.inc;
|
source include/wait_for_slave_io_to_stop.inc;
|
||||||
|
|
||||||
let $file= query_get_value("SHOW SLAVE STATUS", Relay_Log_File, 1);
|
let $file= query_get_value("SHOW SLAVE STATUS", Relay_Log_File, 1);
|
||||||
--replace_result $MYSQLD_SLAVE_DATADIR MYSQLD_SLAVE_DATADIR
|
|
||||||
--exec echo "failure" > $MYSQLD_SLAVE_DATADIR/$file
|
--let FILE_TO_CORRUPT= $MYSQLD_SLAVE_DATADIR/$file
|
||||||
|
perl;
|
||||||
|
$file= $ENV{'FILE_TO_CORRUPT'};
|
||||||
|
open(FILE, ">$file") || die "Unable to open $file.";
|
||||||
|
truncate(FILE,0);
|
||||||
|
print FILE "failure";
|
||||||
|
close ($file);
|
||||||
|
EOF
|
||||||
|
|
||||||
--exec echo "restart" > $MYSQLTEST_VARDIR/tmp/mysqld.2.expect
|
--exec echo "restart" > $MYSQLTEST_VARDIR/tmp/mysqld.2.expect
|
||||||
SET SESSION debug="d,crash_before_rotate_relaylog";
|
SET SESSION debug="d,crash_before_rotate_relaylog";
|
||||||
@@ -102,9 +109,6 @@ insert into t1(a) values(8);
|
|||||||
insert into t1(a) values(9);
|
insert into t1(a) values(9);
|
||||||
|
|
||||||
connection slave;
|
connection slave;
|
||||||
--replace_result $MYSQLD_SLAVE_DATADIR MYSQLD_SLAVE_DATADIR
|
|
||||||
--exec cat $MYSQLD_SLAVE_DATADIR/master.backup > $MYSQLD_SLAVE_DATADIR/master.info
|
|
||||||
|
|
||||||
let MYSQLD_SLAVE_DATADIR=`select @@datadir`;
|
let MYSQLD_SLAVE_DATADIR=`select @@datadir`;
|
||||||
|
|
||||||
--perl
|
--perl
|
||||||
|
@@ -6449,9 +6449,7 @@ int Append_block_log_event::do_apply_event(Relay_log_info const *rli)
|
|||||||
|
|
||||||
DBUG_EXECUTE_IF("remove_slave_load_file_before_write",
|
DBUG_EXECUTE_IF("remove_slave_load_file_before_write",
|
||||||
{
|
{
|
||||||
mysql_file_close(fd, MYF(0));
|
my_delete_allow_opened(fname, MYF(0));
|
||||||
fd= -1;
|
|
||||||
mysql_file_delete(0, fname, MYF(0));
|
|
||||||
});
|
});
|
||||||
|
|
||||||
if (mysql_file_write(fd, (uchar*) block, block_len, MYF(MY_WME+MY_NABP)))
|
if (mysql_file_write(fd, (uchar*) block, block_len, MYF(MY_WME+MY_NABP)))
|
||||||
|
Reference in New Issue
Block a user