#--source include/master-slave.inc
--source include/paxos.inc
--source include/have_binlog_format_row.inc

--connect (conn1,127.0.0.1,root,,test,$MYPORT_1)
--connect (conn2,127.0.0.1,root,,test,$MYPORT_2)

#--disable_query_log
#call mtr.add_suppression("Slave SQL for channel.* The slave coordinator and worker threads are stopped,.*Error_code: 1756");
#call mtr.add_suppression("Slave SQL for channel.* Could not execute Write_rows event on table test.t1;.*");
#call mtr.add_suppression("Slave SQL for channel.* Could not execute Update_rows event on table test.t1;.*");
#call mtr.add_suppression("Slave: Can't find record in 't1'*");
#--enable_query_log

connection conn2;
show global variables like "binlog_format";
show global variables like "slave_exec_mode";

connection conn1;
show global variables like "binlog_format";
show global variables like "binlog_row_image";

#connection master;
create table `t1`(
  `pk` int(11) not null default '0',
  `uk` int(11),
  `a`  int(11),
  primary key(`pk`),
  unique key(`uk`)
)engine=innodb default charset=gbk;

insert into t1 values(1,1,1);
#sync_slave_with_master;
--source include/wait_follower_catchup.inc

select * from t1;

#connection slave;
connection conn2;
set force_revise=ON;
set sql_log_bin=OFF;
delete from t1 where pk=1;
select * from t1;
set force_revise=OFF;
set sql_log_bin=ON;

#connection master;
connection conn1;
update t1 set uk=10 where pk=1;
select * from t1;

#connection slave;
connection conn2;
let $slave_sql_errno= 1032;
source include/wait_for_slave_sql_error.inc;

#source include/stop_slave_io.inc;
#RESET SLAVE;

#connection slave;
connection conn2;
select * from t1;
#drop table t1;

#connection master;
connection conn1;
select * from t1;
drop table t1;