^^&&^^

Edit File: rpl_row_mts_crash_safe.result

include/master-slave.inc
Warnings:
Note	####	Sending passwords in plain text without SSL/TLS is extremely insecure.
Note	####	Storing MySQL user name or password information in the master info repository is not secure and is therefore not recommended. Please consider using the USER and PASSWORD connection options for START SLAVE; see the 'START SLAVE Syntax' in the MySQL Manual for more information.
[connection master]
call mtr.add_suppression('Attempting backtrace');
call mtr.add_suppression("Recovery from master pos .*");
call mtr.add_suppression(".*  InnoDB: Warning: allocated tablespace .*, old maximum was .*");
call mtr.add_suppression(".*int __cxa_pure_virtual().*");
########################################################################
#                               SET UP
########################################################################
'Big rpl_mts_crash_safe'
==== begin rpl_mts_crash_safe.inc:configure ====
---- begin configure database test_1 ----
rpl_mixing_engines.inc [commands=configure]
CREATE TABLE nt_1 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE nt_2 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE nt_3 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE nt_4 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE nt_5 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE nt_6 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE tt_1 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
CREATE TABLE tt_2 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
CREATE TABLE tt_3 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
CREATE TABLE tt_4 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
CREATE TABLE tt_5 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
CREATE TABLE tt_6 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
INSERT INTO nt_1(trans_id, stmt_id) VALUES(1,1);
INSERT INTO nt_2(trans_id, stmt_id) VALUES(1,1);
INSERT INTO nt_3(trans_id, stmt_id) VALUES(1,1);
INSERT INTO nt_4(trans_id, stmt_id) VALUES(1,1);
INSERT INTO nt_5(trans_id, stmt_id) VALUES(1,1);
INSERT INTO nt_6(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_1(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_2(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_3(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_4(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_5(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_6(trans_id, stmt_id) VALUES(1,1);
CREATE PROCEDURE pc_i_tt_5_suc (IN p_trans_id INTEGER, IN p_stmt_id INTEGER)
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM tt_5 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO tt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
INSERT INTO tt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id + 1);
END|
CREATE PROCEDURE pc_i_nt_5_suc (IN p_trans_id INTEGER, IN p_stmt_id INTEGER)
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM nt_5 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO nt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
INSERT INTO nt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id + 1);
END|
CREATE FUNCTION fc_i_tt_5_suc (p_trans_id INTEGER, p_stmt_id INTEGER) RETURNS VARCHAR(64)
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM tt_5 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO tt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
INSERT INTO tt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id + 1);
RETURN "fc_i_tt_5_suc";
END|
CREATE FUNCTION fc_i_nt_5_suc (p_trans_id INTEGER, p_stmt_id INTEGER) RETURNS VARCHAR(64)
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM nt_5 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO nt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
INSERT INTO nt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id + 1);
RETURN "fc_i_nt_5_suc";
END|
CREATE FUNCTION fc_i_nt_3_tt_3_suc (p_trans_id INTEGER, p_stmt_id INTEGER) RETURNS VARCHAR(64)
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM nt_3 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO nt_3(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
SELECT max(stmt_id) INTO in_stmt_id FROM tt_3 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO tt_3(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
RETURN "fc_i_nt_3_tt_3_suc";
END|
CREATE TRIGGER tr_i_tt_3_to_nt_3 AFTER INSERT ON tt_3 FOR EACH ROW
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM nt_3 WHERE trans_id= NEW.trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, NEW.stmt_id), 1) INTO in_stmt_id;
INSERT INTO nt_3(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id);
INSERT INTO nt_3(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id + 1);
END|
CREATE TRIGGER tr_i_nt_4_to_tt_4 AFTER INSERT ON nt_4 FOR EACH ROW
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM tt_4 WHERE trans_id= NEW.trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, NEW.stmt_id), 1) INTO in_stmt_id;
INSERT INTO tt_4(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id);
INSERT INTO tt_4(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id + 1);
END|
CREATE TRIGGER tr_i_tt_5_to_tt_6 AFTER INSERT ON tt_5 FOR EACH ROW
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM tt_6 WHERE trans_id= NEW.trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, NEW.stmt_id, 1), 1) INTO in_stmt_id;
INSERT INTO tt_6(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id);
INSERT INTO tt_6(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id + 1);
END|
CREATE TRIGGER tr_i_nt_5_to_nt_6 AFTER INSERT ON nt_5 FOR EACH ROW
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM nt_6 WHERE trans_id= NEW.trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, NEW.stmt_id), 1) INTO in_stmt_id;
INSERT INTO nt_6(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id);
INSERT INTO nt_6(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id + 1);
END|
---- end configure database test_1 ----
---- begin configure database test_2 ----
rpl_mixing_engines.inc [commands=configure]
CREATE TABLE nt_1 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE nt_2 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE nt_3 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE nt_4 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE nt_5 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE nt_6 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE tt_1 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
CREATE TABLE tt_2 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
CREATE TABLE tt_3 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
CREATE TABLE tt_4 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
CREATE TABLE tt_5 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
CREATE TABLE tt_6 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
INSERT INTO nt_1(trans_id, stmt_id) VALUES(1,1);
INSERT INTO nt_2(trans_id, stmt_id) VALUES(1,1);
INSERT INTO nt_3(trans_id, stmt_id) VALUES(1,1);
INSERT INTO nt_4(trans_id, stmt_id) VALUES(1,1);
INSERT INTO nt_5(trans_id, stmt_id) VALUES(1,1);
INSERT INTO nt_6(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_1(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_2(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_3(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_4(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_5(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_6(trans_id, stmt_id) VALUES(1,1);
CREATE PROCEDURE pc_i_tt_5_suc (IN p_trans_id INTEGER, IN p_stmt_id INTEGER)
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM tt_5 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO tt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
INSERT INTO tt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id + 1);
END|
CREATE PROCEDURE pc_i_nt_5_suc (IN p_trans_id INTEGER, IN p_stmt_id INTEGER)
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM nt_5 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO nt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
INSERT INTO nt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id + 1);
END|
CREATE FUNCTION fc_i_tt_5_suc (p_trans_id INTEGER, p_stmt_id INTEGER) RETURNS VARCHAR(64)
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM tt_5 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO tt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
INSERT INTO tt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id + 1);
RETURN "fc_i_tt_5_suc";
END|
CREATE FUNCTION fc_i_nt_5_suc (p_trans_id INTEGER, p_stmt_id INTEGER) RETURNS VARCHAR(64)
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM nt_5 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO nt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
INSERT INTO nt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id + 1);
RETURN "fc_i_nt_5_suc";
END|
CREATE FUNCTION fc_i_nt_3_tt_3_suc (p_trans_id INTEGER, p_stmt_id INTEGER) RETURNS VARCHAR(64)
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM nt_3 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO nt_3(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
SELECT max(stmt_id) INTO in_stmt_id FROM tt_3 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO tt_3(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
RETURN "fc_i_nt_3_tt_3_suc";
END|
CREATE TRIGGER tr_i_tt_3_to_nt_3 AFTER INSERT ON tt_3 FOR EACH ROW
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM nt_3 WHERE trans_id= NEW.trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, NEW.stmt_id), 1) INTO in_stmt_id;
INSERT INTO nt_3(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id);
INSERT INTO nt_3(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id + 1);
END|
CREATE TRIGGER tr_i_nt_4_to_tt_4 AFTER INSERT ON nt_4 FOR EACH ROW
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM tt_4 WHERE trans_id= NEW.trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, NEW.stmt_id), 1) INTO in_stmt_id;
INSERT INTO tt_4(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id);
INSERT INTO tt_4(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id + 1);
END|
CREATE TRIGGER tr_i_tt_5_to_tt_6 AFTER INSERT ON tt_5 FOR EACH ROW
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM tt_6 WHERE trans_id= NEW.trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, NEW.stmt_id, 1), 1) INTO in_stmt_id;
INSERT INTO tt_6(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id);
INSERT INTO tt_6(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id + 1);
END|
CREATE TRIGGER tr_i_nt_5_to_nt_6 AFTER INSERT ON nt_5 FOR EACH ROW
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM nt_6 WHERE trans_id= NEW.trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, NEW.stmt_id), 1) INTO in_stmt_id;
INSERT INTO nt_6(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id);
INSERT INTO nt_6(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id + 1);
END|
---- end configure database test_2 ----
---- begin configure database test_3 ----
rpl_mixing_engines.inc [commands=configure]
CREATE TABLE nt_1 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE nt_2 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE nt_3 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE nt_4 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE nt_5 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE nt_6 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = MyISAM;
CREATE TABLE tt_1 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
CREATE TABLE tt_2 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
CREATE TABLE tt_3 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
CREATE TABLE tt_4 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
CREATE TABLE tt_5 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
CREATE TABLE tt_6 (trans_id INT, stmt_id INT, info VARCHAR(64), PRIMARY KEY(trans_id, stmt_id)) ENGINE = "Innodb";
INSERT INTO nt_1(trans_id, stmt_id) VALUES(1,1);
INSERT INTO nt_2(trans_id, stmt_id) VALUES(1,1);
INSERT INTO nt_3(trans_id, stmt_id) VALUES(1,1);
INSERT INTO nt_4(trans_id, stmt_id) VALUES(1,1);
INSERT INTO nt_5(trans_id, stmt_id) VALUES(1,1);
INSERT INTO nt_6(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_1(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_2(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_3(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_4(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_5(trans_id, stmt_id) VALUES(1,1);
INSERT INTO tt_6(trans_id, stmt_id) VALUES(1,1);
CREATE PROCEDURE pc_i_tt_5_suc (IN p_trans_id INTEGER, IN p_stmt_id INTEGER)
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM tt_5 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO tt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
INSERT INTO tt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id + 1);
END|
CREATE PROCEDURE pc_i_nt_5_suc (IN p_trans_id INTEGER, IN p_stmt_id INTEGER)
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM nt_5 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO nt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
INSERT INTO nt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id + 1);
END|
CREATE FUNCTION fc_i_tt_5_suc (p_trans_id INTEGER, p_stmt_id INTEGER) RETURNS VARCHAR(64)
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM tt_5 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO tt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
INSERT INTO tt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id + 1);
RETURN "fc_i_tt_5_suc";
END|
CREATE FUNCTION fc_i_nt_5_suc (p_trans_id INTEGER, p_stmt_id INTEGER) RETURNS VARCHAR(64)
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM nt_5 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO nt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
INSERT INTO nt_5(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id + 1);
RETURN "fc_i_nt_5_suc";
END|
CREATE FUNCTION fc_i_nt_3_tt_3_suc (p_trans_id INTEGER, p_stmt_id INTEGER) RETURNS VARCHAR(64)
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM nt_3 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO nt_3(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
SELECT max(stmt_id) INTO in_stmt_id FROM tt_3 WHERE trans_id= p_trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, p_stmt_id), 1) INTO in_stmt_id;
INSERT INTO tt_3(trans_id, stmt_id) VALUES (p_trans_id, in_stmt_id);
RETURN "fc_i_nt_3_tt_3_suc";
END|
CREATE TRIGGER tr_i_tt_3_to_nt_3 AFTER INSERT ON tt_3 FOR EACH ROW
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM nt_3 WHERE trans_id= NEW.trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, NEW.stmt_id), 1) INTO in_stmt_id;
INSERT INTO nt_3(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id);
INSERT INTO nt_3(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id + 1);
END|
CREATE TRIGGER tr_i_nt_4_to_tt_4 AFTER INSERT ON nt_4 FOR EACH ROW
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM tt_4 WHERE trans_id= NEW.trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, NEW.stmt_id), 1) INTO in_stmt_id;
INSERT INTO tt_4(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id);
INSERT INTO tt_4(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id + 1);
END|
CREATE TRIGGER tr_i_tt_5_to_tt_6 AFTER INSERT ON tt_5 FOR EACH ROW
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM tt_6 WHERE trans_id= NEW.trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, NEW.stmt_id, 1), 1) INTO in_stmt_id;
INSERT INTO tt_6(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id);
INSERT INTO tt_6(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id + 1);
END|
CREATE TRIGGER tr_i_nt_5_to_nt_6 AFTER INSERT ON nt_5 FOR EACH ROW
BEGIN
DECLARE in_stmt_id INTEGER;
SELECT max(stmt_id) INTO in_stmt_id FROM nt_6 WHERE trans_id= NEW.trans_id;
SELECT COALESCE(greatest(in_stmt_id + 1, NEW.stmt_id), 1) INTO in_stmt_id;
INSERT INTO nt_6(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id);
INSERT INTO nt_6(trans_id, stmt_id) VALUES (NEW.trans_id, in_stmt_id + 1);
END|
---- end configure database test_3 ----
include/stop_slave.inc
SHOW CREATE TABLE mysql.slave_master_info;
Table	Create Table
slave_master_info	CREATE TABLE `slave_master_info` (
  `Number_of_lines` int(10) unsigned NOT NULL COMMENT 'Number of lines in the file.',
  `Master_log_name` text CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT 'The name of the master binary log currently being read from the master.',
  `Master_log_pos` bigint(20) unsigned NOT NULL COMMENT 'The master log position of the last read event.',
  `Host` char(64) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT 'The host name of the master.',
  `User_name` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The user name used to connect to the master.',
  `User_password` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The password used to connect to the master.',
  `Port` int(10) unsigned NOT NULL COMMENT 'The network port used to connect to the master.',
  `Connect_retry` int(10) unsigned NOT NULL COMMENT 'The period (in seconds) that the slave will wait before trying to reconnect to the master.',
  `Enabled_ssl` tinyint(1) NOT NULL COMMENT 'Indicates whether the server supports SSL connections.',
  `Ssl_ca` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The file used for the Certificate Authority (CA) certificate.',
  `Ssl_capath` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The path to the Certificate Authority (CA) certificates.',
  `Ssl_cert` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The name of the SSL certificate file.',
  `Ssl_cipher` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The name of the cipher in use for the SSL connection.',
  `Ssl_key` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The name of the SSL key file.',
  `Ssl_verify_server_cert` tinyint(1) NOT NULL COMMENT 'Whether to verify the server certificate.',
  `Heartbeat` float NOT NULL,
  `Bind` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'Displays which interface is employed when connecting to the MySQL server',
  `Ignored_server_ids` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The number of server IDs to be ignored, followed by the actual server IDs',
  `Uuid` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The master server uuid.',
  `Retry_count` bigint(20) unsigned NOT NULL COMMENT 'Number of reconnect attempts, to the master, before giving up.',
  `Ssl_crl` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The file used for the Certificate Revocation List (CRL)',
  `Ssl_crlpath` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The path used for Certificate Revocation List (CRL) files',
  `Enabled_auto_position` tinyint(1) NOT NULL COMMENT 'Indicates whether GTIDs will be used to retrieve events from the master.',
  PRIMARY KEY (`Host`,`Port`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 STATS_PERSISTENT=0 COMMENT='Master Information'
SHOW CREATE TABLE mysql.slave_relay_log_info;
Table	Create Table
slave_relay_log_info	CREATE TABLE `slave_relay_log_info` (
  `Number_of_lines` int(10) unsigned NOT NULL COMMENT 'Number of lines in the file or rows in the table. Used to version table definitions.',
  `Relay_log_name` text CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT 'The name of the current relay log file.',
  `Relay_log_pos` bigint(20) unsigned NOT NULL COMMENT 'The relay log position of the last executed event.',
  `Master_log_name` text CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT 'The name of the master binary log file from which the events in the relay log file were read.',
  `Master_log_pos` bigint(20) unsigned NOT NULL COMMENT 'The master log position of the last executed event.',
  `Sql_delay` int(11) NOT NULL COMMENT 'The number of seconds that the slave must lag behind the master.',
  `Number_of_workers` int(10) unsigned NOT NULL,
  `Id` int(10) unsigned NOT NULL COMMENT 'Internal Id that uniquely identifies this record.',
  PRIMARY KEY (`Id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 STATS_PERSISTENT=0 COMMENT='Relay Log Information'
SHOW CREATE TABLE mysql.slave_worker_info;
Table	Create Table
slave_worker_info	CREATE TABLE `slave_worker_info` (
  `Id` int(10) unsigned NOT NULL,
  `Relay_log_name` text CHARACTER SET utf8 COLLATE utf8_bin NOT NULL,
  `Relay_log_pos` bigint(20) unsigned NOT NULL,
  `Master_log_name` text CHARACTER SET utf8 COLLATE utf8_bin NOT NULL,
  `Master_log_pos` bigint(20) unsigned NOT NULL,
  `Checkpoint_relay_log_name` text CHARACTER SET utf8 COLLATE utf8_bin NOT NULL,
  `Checkpoint_relay_log_pos` bigint(20) unsigned NOT NULL,
  `Checkpoint_master_log_name` text CHARACTER SET utf8 COLLATE utf8_bin NOT NULL,
  `Checkpoint_master_log_pos` bigint(20) unsigned NOT NULL,
  `Checkpoint_seqno` int(10) unsigned NOT NULL,
  `Checkpoint_group_size` int(10) unsigned NOT NULL,
  `Checkpoint_group_bitmap` blob NOT NULL,
  PRIMARY KEY (`Id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 STATS_PERSISTENT=0 COMMENT='Worker Information'
ALTER TABLE mysql.slave_master_info ENGINE= Innodb;
ALTER TABLE mysql.slave_relay_log_info ENGINE= Innodb;
ALTER TABLE mysql.slave_worker_info ENGINE= Innodb;
SHOW CREATE TABLE mysql.slave_master_info;
Table	Create Table
slave_master_info	CREATE TABLE `slave_master_info` (
  `Number_of_lines` int(10) unsigned NOT NULL COMMENT 'Number of lines in the file.',
  `Master_log_name` text CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT 'The name of the master binary log currently being read from the master.',
  `Master_log_pos` bigint(20) unsigned NOT NULL COMMENT 'The master log position of the last read event.',
  `Host` char(64) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL DEFAULT '' COMMENT 'The host name of the master.',
  `User_name` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The user name used to connect to the master.',
  `User_password` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The password used to connect to the master.',
  `Port` int(10) unsigned NOT NULL COMMENT 'The network port used to connect to the master.',
  `Connect_retry` int(10) unsigned NOT NULL COMMENT 'The period (in seconds) that the slave will wait before trying to reconnect to the master.',
  `Enabled_ssl` tinyint(1) NOT NULL COMMENT 'Indicates whether the server supports SSL connections.',
  `Ssl_ca` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The file used for the Certificate Authority (CA) certificate.',
  `Ssl_capath` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The path to the Certificate Authority (CA) certificates.',
  `Ssl_cert` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The name of the SSL certificate file.',
  `Ssl_cipher` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The name of the cipher in use for the SSL connection.',
  `Ssl_key` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The name of the SSL key file.',
  `Ssl_verify_server_cert` tinyint(1) NOT NULL COMMENT 'Whether to verify the server certificate.',
  `Heartbeat` float NOT NULL,
  `Bind` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'Displays which interface is employed when connecting to the MySQL server',
  `Ignored_server_ids` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The number of server IDs to be ignored, followed by the actual server IDs',
  `Uuid` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The master server uuid.',
  `Retry_count` bigint(20) unsigned NOT NULL COMMENT 'Number of reconnect attempts, to the master, before giving up.',
  `Ssl_crl` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The file used for the Certificate Revocation List (CRL)',
  `Ssl_crlpath` text CHARACTER SET utf8 COLLATE utf8_bin COMMENT 'The path used for Certificate Revocation List (CRL) files',
  `Enabled_auto_position` tinyint(1) NOT NULL COMMENT 'Indicates whether GTIDs will be used to retrieve events from the master.',
  PRIMARY KEY (`Host`,`Port`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 STATS_PERSISTENT=0 COMMENT='Master Information'
SHOW CREATE TABLE mysql.slave_relay_log_info;
Table	Create Table
slave_relay_log_info	CREATE TABLE `slave_relay_log_info` (
  `Number_of_lines` int(10) unsigned NOT NULL COMMENT 'Number of lines in the file or rows in the table. Used to version table definitions.',
  `Relay_log_name` text CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT 'The name of the current relay log file.',
  `Relay_log_pos` bigint(20) unsigned NOT NULL COMMENT 'The relay log position of the last executed event.',
  `Master_log_name` text CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT 'The name of the master binary log file from which the events in the relay log file were read.',
  `Master_log_pos` bigint(20) unsigned NOT NULL COMMENT 'The master log position of the last executed event.',
  `Sql_delay` int(11) NOT NULL COMMENT 'The number of seconds that the slave must lag behind the master.',
  `Number_of_workers` int(10) unsigned NOT NULL,
  `Id` int(10) unsigned NOT NULL COMMENT 'Internal Id that uniquely identifies this record.',
  PRIMARY KEY (`Id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 STATS_PERSISTENT=0 COMMENT='Relay Log Information'
SHOW CREATE TABLE mysql.slave_worker_info;
Table	Create Table
slave_worker_info	CREATE TABLE `slave_worker_info` (
  `Id` int(10) unsigned NOT NULL,
  `Relay_log_name` text CHARACTER SET utf8 COLLATE utf8_bin NOT NULL,
  `Relay_log_pos` bigint(20) unsigned NOT NULL,
  `Master_log_name` text CHARACTER SET utf8 COLLATE utf8_bin NOT NULL,
  `Master_log_pos` bigint(20) unsigned NOT NULL,
  `Checkpoint_relay_log_name` text CHARACTER SET utf8 COLLATE utf8_bin NOT NULL,
  `Checkpoint_relay_log_pos` bigint(20) unsigned NOT NULL,
  `Checkpoint_master_log_name` text CHARACTER SET utf8 COLLATE utf8_bin NOT NULL,
  `Checkpoint_master_log_pos` bigint(20) unsigned NOT NULL,
  `Checkpoint_seqno` int(10) unsigned NOT NULL,
  `Checkpoint_group_size` int(10) unsigned NOT NULL,
  `Checkpoint_group_bitmap` blob NOT NULL,
  PRIMARY KEY (`Id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 STATS_PERSISTENT=0 COMMENT='Worker Information'
==== end rpl_mts_crash_safe.inc:configure ====
########################################################################
#                                TEST 
########################################################################
SET @@global.slave_parallel_workers= 1;
SET @@global.slave_checkpoint_period= 0;
Generating Number of Workers 1 --- Number of Groups per worker 1 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (7, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (7, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (9, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (9, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (11, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (11, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (12, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (12, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (15, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (15, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (17, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (17, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (18, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (18, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 1 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (20, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (20, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (22, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (22, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (23, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (23, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (24, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (24, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (26, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (26, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (27, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (27, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (28, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (28, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (29, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (29, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (30, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (30, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 1 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (32, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (32, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (34, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (34, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (35, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (35, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (36, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (36, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (38, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (38, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (39, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (39, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (40, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (40, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (41, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (41, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (42, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (42, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 1 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (44, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (44, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 1 --- Debugging Groups 1 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (45, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (45, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (47, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (47, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (48, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (48, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (49, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (49, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (50, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (50, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (51, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (51, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (53, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (53, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (54, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (54, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (55, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (55, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (56, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (56, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (57, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (57, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (58, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (58, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (59, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (59, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (60, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (60, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 1 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (62, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (62, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 1 --- Debugging Groups 1 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (63, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (63, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (65, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (65, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (66, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (66, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (67, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (67, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (68, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (68, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 1 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (69, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (69, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (71, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (71, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (72, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (72, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (73, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (73, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (74, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (74, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (75, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (75, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (76, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (76, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (77, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (77, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 1 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (78, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (78, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (80, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (80, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (82, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (82, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (83, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (83, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (85, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (85, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (87, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (87, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (88, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (88, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (90, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (90, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (92, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (92, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (93, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (93, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (95, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (95, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (96, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (96, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (97, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (97, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (99, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (99, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (100, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (100, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (101, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (101, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (102, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (102, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (103, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (103, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (105, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (105, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (106, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (106, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (107, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (107, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (109, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (109, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (110, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (110, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (111, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (111, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (112, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (112, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (113, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (113, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (115, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (115, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (116, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (116, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (117, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (117, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (119, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (119, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (120, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (120, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (121, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (121, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (122, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (122, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (123, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (123, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (125, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (125, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (126, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (126, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (127, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (127, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (128, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (128, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (129, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (129, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (131, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (131, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (132, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (132, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (133, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (133, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (134, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (134, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (135, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (135, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (136, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (136, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (137, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (137, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (138, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (138, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (140, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (140, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (141, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (141, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (142, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (142, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (143, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (143, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (144, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (144, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (146, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (146, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (147, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (147, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (148, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (148, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (149, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (149, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (150, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (150, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (151, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (151, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (152, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (152, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (153, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (153, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (155, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (155, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (156, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (156, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (157, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (157, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (158, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (158, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 2 --- Debugging Groups 2 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (159, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (159, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (161, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (161, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (162, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (162, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (163, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (163, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (164, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (164, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (165, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (165, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (166, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (166, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (167, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (167, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 2 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (168, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (168, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (170, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (170, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (171, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (171, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (173, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (173, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (174, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (174, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (176, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (176, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (177, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (177, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (179, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (179, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 1 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (180, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (180, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (182, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (182, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (183, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (183, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (184, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (184, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (185, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (185, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (186, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (186, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (188, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (188, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (189, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (189, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (190, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (190, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (191, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (191, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (192, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (192, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (194, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (194, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (195, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (195, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (196, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (196, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (197, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (197, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (198, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (198, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (200, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (200, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (201, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (201, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (202, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (202, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (203, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (203, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 2 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (204, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (204, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (206, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (206, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (207, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (207, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (208, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (208, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (209, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (209, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (210, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (210, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (211, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (211, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (212, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (212, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (213, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (213, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (215, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (215, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (216, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (216, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (217, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (217, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (218, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (218, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (219, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (219, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (220, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (220, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (221, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (221, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (222, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (222, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (224, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (224, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (225, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (225, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (226, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (226, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (227, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (227, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (228, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (228, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (229, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (229, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (230, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (230, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (231, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (231, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (233, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (233, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (234, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (234, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (235, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (235, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (236, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (236, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (237, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (237, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_1
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (238, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (238, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_1.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_2
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (239, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (239, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_2.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
Generating Number of Workers 3 --- Number of Groups per worker 3 --- Debugging Groups 3 --- Database test_3
==== begin rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
rpl_mixing_engines.inc [commands=B T T C]
BEGIN;
INSERT INTO tt_1(trans_id, stmt_id) VALUES (240, 2);
INSERT INTO tt_1(trans_id, stmt_id) VALUES (240, 4);
COMMIT;
-b-b-b-b-b-b-b-b-b-b-b- >> B T T C << -b-b-b-b-b-b-b-b-b-b-b-
include/show_binlog_events.inc
Log_name	Pos	Event_type	Server_id	End_log_pos	Info
master-bin.000001	#	Query	#	#	BEGIN
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Table_map	#	#	table_id: # (test_3.tt_1)
master-bin.000001	#	Write_rows	#	#	table_id: # flags: STMT_END_F
master-bin.000001	#	Xid	#	#	COMMIT /* XID */
-e-e-e-e-e-e-e-e-e-e-e- >> B T T C << -e-e-e-e-e-e-e-e-e-e-e-

==== end rpl_mts_crash_safe.inc:rpl_mixing_engines.inc ====
----Executing----
==== begin rpl_mts_crash_safe.inc:recovery ====
include/start_slave_io.inc
** fixing gaps **
include/rpl_start_server.inc [server_number=2 parameters: --skip-slave-start --relay-log-recovery=0 --slave-parallel-workers=0]
START SLAVE UNTIL SQL_AFTER_MTS_GAPS;
include/wait_for_slave_param.inc [Until_Condition]
include/wait_for_slave_sql_to_stop.inc
** regular restart **
include/rpl_restart_server.inc [server_number=2 parameters: --skip-slave-start --slave-transaction-retries=0 --relay-log-info-repository=TABLE --master-info-repository=TABLE --sync-master-info=1]
include/start_slave_io.inc
include/start_slave_sql.inc
include/stop_slave.inc
SET @@global.slave_parallel_workers= 3;
SET @@global.slave_checkpoint_period= 3;
==== end rpl_mts_crash_safe.inc:recovery ====
########################################################################
#                          CHECK CONSISTENCY
########################################################################
include/start_slave.inc
include/sync_slave_sql_with_master.inc
########################################################################
#                             CLEAN UP
########################################################################
==== begin rpl_mts_crash_safe.inc:clean ====
include/stop_slave.inc
include/start_slave.inc
---- begin clean database test_1 ----
rpl_mixing_engines.inc [commands=clean]
DROP TABLE tt_1;
DROP TABLE tt_2;
DROP TABLE tt_3;
DROP TABLE tt_4;
DROP TABLE tt_5;
DROP TABLE tt_6;
DROP TABLE nt_1;
DROP TABLE nt_2;
DROP TABLE nt_3;
DROP TABLE nt_4;
DROP TABLE nt_5;
DROP TABLE nt_6;
DROP PROCEDURE pc_i_tt_5_suc;
DROP PROCEDURE pc_i_nt_5_suc;
DROP FUNCTION fc_i_tt_5_suc;
DROP FUNCTION fc_i_nt_5_suc;
DROP FUNCTION fc_i_nt_3_tt_3_suc;
---- end clean database test_1 ----
---- begin clean database test_2 ----
rpl_mixing_engines.inc [commands=clean]
DROP TABLE tt_1;
DROP TABLE tt_2;
DROP TABLE tt_3;
DROP TABLE tt_4;
DROP TABLE tt_5;
DROP TABLE tt_6;
DROP TABLE nt_1;
DROP TABLE nt_2;
DROP TABLE nt_3;
DROP TABLE nt_4;
DROP TABLE nt_5;
DROP TABLE nt_6;
DROP PROCEDURE pc_i_tt_5_suc;
DROP PROCEDURE pc_i_nt_5_suc;
DROP FUNCTION fc_i_tt_5_suc;
DROP FUNCTION fc_i_nt_5_suc;
DROP FUNCTION fc_i_nt_3_tt_3_suc;
---- end clean database test_2 ----
---- begin clean database test_3 ----
rpl_mixing_engines.inc [commands=clean]
DROP TABLE tt_1;
DROP TABLE tt_2;
DROP TABLE tt_3;
DROP TABLE tt_4;
DROP TABLE tt_5;
DROP TABLE tt_6;
DROP TABLE nt_1;
DROP TABLE nt_2;
DROP TABLE nt_3;
DROP TABLE nt_4;
DROP TABLE nt_5;
DROP TABLE nt_6;
DROP PROCEDURE pc_i_tt_5_suc;
DROP PROCEDURE pc_i_nt_5_suc;
DROP FUNCTION fc_i_tt_5_suc;
DROP FUNCTION fc_i_nt_5_suc;
DROP FUNCTION fc_i_nt_3_tt_3_suc;
---- end clean database test_3 ----
==== end rpl_mts_crash_safe.inc:clean ====
include/rpl_end.inc