--source include/have_rocksdb.inc
--source include/master-slave.inc
--source include/have_binlog_format_row.inc

--disable_warnings
DROP TABLE IF EXISTS t1;
connection slave;
--source include/stop_slave.inc
--enable_warnings

connection master;
create table t1 (a int, b int, primary key (a), unique key (b)) engine=rocksdb;
--disable_query_log
--let $aa= 0
while ($aa < 1000) {
  eval insert into t1 values ($aa, $aa);
  --inc $aa
}
--enable_query_log

connection slave;
show variables like 'rpl_skip_tx_api';
--source include/start_slave.inc

--let $it=0
--let $stop=0
while ($stop != 1) {
let $count= query_get_value(select count(*) as Value from information_schema.rocksdb_trx, Value, 1);
  if ($count) {
    --echo found
    --let $stop=1
  }

  if ($it > 1000) {
    --echo not found
    --let $stop=1
  }

  --inc $it
}

connection master;
DROP TABLE t1;
--source include/rpl_end.inc