--source include/master-slave.inc

--source include/have_binlog_format_row.inc

--connection slave

--source include/stop_slave_sql.inc

--connection master

create table t1 (i int);

flush logs;

insert into t1 values (1),(2);

insert into t1 values (3),(4);

insert into t1 values (5),(6);

insert into t1 values (7),(8);

insert into t1 values (9),(10);

--let $master_file = query_get_value(show master status,File,1)

--let $master_pos = query_get_value(show master status,Position,1)

insert into t1 values (11),(12);

insert into t1 values (13),(14);

insert into t1 values (15),(16);

--connection slave

set global slave_parallel_threads = 1;

eval start slave until master_log_file='$master_file', master_log_pos=$master_pos;

--let $show_statement = SHOW SLAVE STATUS

--let $field = Slave_SQL_Running

--let $condition = = 'No'

--let $wait_timeout = 10

--source include/wait_show_condition.inc

if (`select COUNT(*) > 10 from t1`) 

{

	SELECT * FROM t1;

	query_vertical show slave status;

	die "Extra rows in the table";

}

drop table t1;

set global slave_parallel_threads = DEFAULT;

--source include/stop_slave_io.inc

--connection master

drop table t1;