[2017-02-27 18:46:50,769] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1488201410000, eventType=QUERY, serverId=13, headerLength=19, dataLength=131, nextPosition=46969821, flags=0}, data=QueryEventData{threadId=173692, executionTime=59, errorCode=0, database='NextErpQa', sql='DROP TEMPORARY TABLE IF EXISTS `_result` /* generated by server */'}} (io.debezium.connector.mysql.BinlogReader:435)
[2017-02-27 18:46:51,194] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1488201411000, eventType=QUERY, serverId=13, headerLength=19, dataLength=118, nextPosition=46970023, flags=0}, data=QueryEventData{threadId=173692, executionTime=59, errorCode=0, database='NextErpQa', sql='DROP TABLE IF EXISTS `_tmp` /* generated by server */'}} (io.debezium.connector.mysql.BinlogReader:435)
[2017-02-27 18:47:07,211] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1488201427000, eventType=QUERY, serverId=13, headerLength=19, dataLength=44, nextPosition=46970151, flags=8}, data=QueryEventData{threadId=150175, executionTime=59, errorCode=0, database='', sql='BEGIN'}} (io.debezium.connector.mysql.BinlogReader:435)
[2017-02-27 18:47:07,211] DEBUG Skipping update table metadata event: Event{header=EventHeaderV4{timestamp=1488201427000, eventType=TABLE_MAP, serverId=13, headerLength=19, dataLength=58, nextPosition=46970228, flags=0}, data=TableMapEventData{tableId=715, database='NextServices', table='SESSION', columnTypes=8, 8, 16, 15, 15, 18, 18, -2, 8, columnMetadata=0, 0, 1, 150, 60, 0, 0, 65040, 0, columnNullability={1, 2, 3, 4, 5, 6, 7, 8}}} (io.debezium.connector.mysql.BinlogReader:491)
[2017-02-27 18:47:07,211] DEBUG Skipping insert row event: Event{header=EventHeaderV4{timestamp=1488201427000, eventType=EXT_WRITE_ROWS, serverId=13, headerLength=19, dataLength=89, nextPosition=46970336, flags=0}, data=WriteRowsEventData{tableId=715, includedColumns={0, 1, 2, 3, 4, 5, 6, 7, 8}, rows=[
    [5920, 1, null, [B@3e156463, [B@1bc17de6, null, 2017-02-27T18:47:07, [B@4bd82a50, 2]
]}} (io.debezium.connector.mysql.BinlogReader:537)
[2017-02-27 18:47:53,011] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1488201472000, eventType=QUERY, serverId=13, headerLength=19, dataLength=131, nextPosition=46970582, flags=0}, data=QueryEventData{threadId=173692, executionTime=59, errorCode=0, database='NextErpQa', sql='DROP TEMPORARY TABLE IF EXISTS `_result` /* generated by server */'}} (io.debezium.connector.mysql.BinlogReader:435)
[2017-02-27 18:48:01,586] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1488201481000, eventType=QUERY, serverId=13, headerLength=19, dataLength=88, nextPosition=46970754, flags=0}, data=QueryEventData{threadId=173692, executionTime=59, errorCode=0, database='NextErpQa', sql='DROP PROCEDURE find_par'}} (io.debezium.connector.mysql.BinlogReader:435)
[2017-02-27 18:48:02,553] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1488201482000, eventType=QUERY, serverId=13, headerLength=19, dataLength=1907, nextPosition=46972745, flags=0}, data=QueryEventData{threadId=173692, executionTime=59, errorCode=0, database='NextErpQa', sql='CREATE DEFINER=`parasshah`@`%` PROCEDURE `find_par`(seed INT)
BEGIN
	
	DECLARE i int default 0;
	
	 DROP TABLE IF EXISTS _result;
	
	 CREATE TEMPORARY TABLE _result (node int primary key,id int,type varchar(20));
	
	 INSERT INTO _result(node,id,type) VALUES(seed,i,'exam');
	
	 DROP TABLE IF EXISTS _tmp;
	
	CREATE TEMPORARY TABLE _tmp (parent_node int,child_node int);
	REPEAT
	TRUNCATE TABLE _tmp;
	INSERT INTO _tmp SELECT EM.PARENT_EXAM_ID as parent_node, _result.node as child_node
	FROM _result JOIN EXAM_MAPPING EM ON EM.CHILD_EXAM_ID = _result.node;  	 
	
	INSERT IGNORE INTO _result(node,id,type) values ((SELECT parent_node FROM _tmp),i+1,'exam' );	
	
	
	
	UNTIL ROW_COUNT() = 0
	END REPEAT;
	
	select max(id) from _result into i;
	
	REPEAT
	TRUNCATE TABLE _tmp;
	
	INSERT INTO _tmp SELECT EM.EXAM_STRUCTURE_ID as parent_node, _result.node as child_node
	FROM _result JOIN EXAM_STRUCTURE_EXAM_MAPPING EM ON EM.EXAM_ID = _result.node and _result.id = i;  
	
	INSERT IGNORE INTO _result(node,id,type) values ((SELECT parent_node FROM _tmp),i+1,'exam_structure');
	
	UNTIL ROW_COUNT() = 0
	END REPEAT;
	
	select max(id) from _result into i;
	
	REPEAT
	TRUNCATE TABLE _tmp;
	
	INSERT INTO _tmp SELECT EM.PARENT_EXAM_STRUCTURE_ID as parent_node, _result.node as child_node
	FROM _result JOIN EXAM_STRUCTURE_MAPPING EM ON EM.CHILD_EXAM_STRUCTURE_ID = _result.node and _result.id = i;  

	if ((SELECT EM.PARENT_EXAM_STRUCTURE_ID as parent_node, _result.node as child_node
	FROM _result JOIN EXAM_STRUCTURE_MAPPING EM ON EM.CHILD_EXAM_STRUCTURE_ID = _result.node and _result.id = i)!= NULL)	then	
	INSERT IGNORE INTO _result(node,id,type) values ((SELECT parent_node FROM _tmp),i+1,'exam_structure');
	end if;
	
	UNTIL ROW_COUNT() = 0
	END REPEAT;
	

	
	TRUNCATE TABLE _tmp;
	
	SELECT * FROM _result;
	
	
	DROP TABLE _tmp;
	
END'}} (io.debezium.connector.mysql.BinlogReader:435)
[2017-02-27 18:48:02,554] ERROR Error parsing DDL statement and updating tables: CREATE DEFINER=`parasshah`@`%` PROCEDURE `find_par`(seed INT)
BEGIN
	
	DECLARE i int default 0;
	
	 DROP TABLE IF EXISTS _result;
	
	 CREATE TEMPORARY TABLE _result (node int primary key,id int,type varchar(20));
	
	 INSERT INTO _result(node,id,type) VALUES(seed,i,'exam');
	
	 DROP TABLE IF EXISTS _tmp;
	
	CREATE TEMPORARY TABLE _tmp (parent_node int,child_node int);
	REPEAT
	TRUNCATE TABLE _tmp;
	INSERT INTO _tmp SELECT EM.PARENT_EXAM_ID as parent_node, _result.node as child_node
	FROM _result JOIN EXAM_MAPPING EM ON EM.CHILD_EXAM_ID = _result.node;  	 
	
	INSERT IGNORE INTO _result(node,id,type) values ((SELECT parent_node FROM _tmp),i+1,'exam' );	
	
	
	
	UNTIL ROW_COUNT() = 0
	END REPEAT;
	
	select max(id) from _result into i;
	
	REPEAT
	TRUNCATE TABLE _tmp;
	
	INSERT INTO _tmp SELECT EM.EXAM_STRUCTURE_ID as parent_node, _result.node as child_node
	FROM _result JOIN EXAM_STRUCTURE_EXAM_MAPPING EM ON EM.EXAM_ID = _result.node and _result.id = i;  
	
	INSERT IGNORE INTO _result(node,id,type) values ((SELECT parent_node FROM _tmp),i+1,'exam_structure');
	
	UNTIL ROW_COUNT() = 0
	END REPEAT;
	
	select max(id) from _result into i;
	
	REPEAT
	TRUNCATE TABLE _tmp;
	
	INSERT INTO _tmp SELECT EM.PARENT_EXAM_STRUCTURE_ID as parent_node, _result.node as child_node
	FROM _result JOIN EXAM_STRUCTURE_MAPPING EM ON EM.CHILD_EXAM_STRUCTURE_ID = _result.node and _result.id = i;  

	if ((SELECT EM.PARENT_EXAM_STRUCTURE_ID as parent_node, _result.node as child_node
	FROM _result JOIN EXAM_STRUCTURE_MAPPING EM ON EM.CHILD_EXAM_STRUCTURE_ID = _result.node and _result.id = i)!= NULL)	then	
	INSERT IGNORE INTO _result(node,id,type) values ((SELECT parent_node FROM _tmp),i+1,'exam_structure');
	end if;
	
	UNTIL ROW_COUNT() = 0
	END REPEAT;
	

	
	TRUNCATE TABLE _tmp;
	
	SELECT * FROM _result;
	
	
	DROP TABLE _tmp;
	
END (io.debezium.connector.mysql.MySqlSchema:353)
io.debezium.text.ParsingException: Expecting token type 128 at line 27, column 2 but found 'select': = 0
	END REPEAT;
	
	 ===>> select max(id) from 
	at io.debezium.text.TokenStream.consume(TokenStream.java:725)
	at io.debezium.relational.ddl.DdlParser.consumeStatement(DdlParser.java:567)
	at io.debezium.relational.ddl.DdlParser.parseUnknownStatement(DdlParser.java:375)
	at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:153)
	at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:285)
	at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:266)
	at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:351)
	at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:461)
	at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:319)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:902)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:760)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:472)
	at com.github.shyiko.mysql.binlog.BinaryLogClient$5.run(BinaryLogClient.java:657)
	at java.lang.Thread.run(Thread.java:745)
[2017-02-27 18:48:03,786] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1488201483000, eventType=QUERY, serverId=13, headerLength=19, dataLength=44, nextPosition=46972873, flags=8}, data=QueryEventData{threadId=150175, executionTime=59, errorCode=0, database='', sql='BEGIN'}} (io.debezium.connector.mysql.BinlogReader:435)
[2017-02-27 18:48:03,786] DEBUG Skipping update table metadata event: Event{header=EventHeaderV4{timestamp=1488201483000, eventType=TABLE_MAP, serverId=13, headerLength=19, dataLength=58, nextPosition=46972950, flags=0}, data=TableMapEventData{tableId=715, database='NextServices', table='SESSION', columnTypes=8, 8, 16, 15, 15, 18, 18, -2, 8, columnMetadata=0, 0, 1, 150, 60, 0, 0, 65040, 0, columnNullability={1, 2, 3, 4, 5, 6, 7, 8}}} (io.debezium.connector.mysql.BinlogReader:491)
[2017-02-27 18:48:03,786] DEBUG Skipping insert row event: Event{header=EventHeaderV4{timestamp=1488201483000, eventType=EXT_WRITE_ROWS, serverId=13, headerLength=19, dataLength=89, nextPosition=46973058, flags=0}, data=WriteRowsEventData{tableId=715, includedColumns={0, 1, 2, 3, 4, 5, 6, 7, 8}, rows=[
    [5921, 113574, null, [B@14117a39, [B@4ceea7ab, null, 2017-02-27T18:48:04, [B@7708dbe1, 328]
]}} (io.debezium.connector.mysql.BinlogReader:537)
[2017-02-27 18:48:04,386] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1488201484000, eventType=QUERY, serverId=13, headerLength=19, dataLength=121, nextPosition=46973294, flags=0}, data=QueryEventData{threadId=173692, executionTime=59, errorCode=0, database='NextErpQa', sql='DROP TABLE IF EXISTS `_result` /* generated by server */'}} (io.debezium.connector.mysql.BinlogReader:435)
[2017-02-27 18:48:04,878] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1488201484000, eventType=QUERY, serverId=13, headerLength=19, dataLength=128, nextPosition=46973506, flags=0}, data=QueryEventData{threadId=173692, executionTime=59, errorCode=0, database='NextErpQa', sql='DROP TEMPORARY TABLE IF EXISTS `_tmp` /* generated by server */'}} (io.debezium.connector.mysql.BinlogReader:435)
[2017-02-27 18:48:11,404] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1488201491000, eventType=QUERY, serverId=13, headerLength=19, dataLength=44, nextPosition=46973634, flags=8}, data=QueryEventData{threadId=150175, executionTime=59, errorCode=0, database='', sql='BEGIN'}} (io.debezium.connector.mysql.BinlogReader:435)
[2017-02-27 18:48:11,404] DEBUG Skipping update table metadata event: Event{header=EventHeaderV4{timestamp=1488201491000, eventType=TABLE_MAP, serverId=13, headerLength=19, dataLength=58, nextPosition=46973711, flags=0}, data=TableMapEventData{tableId=715, database='NextServices', table='SESSION', columnTypes=8, 8, 16, 15, 15, 18, 18, -2, 8, columnMetadata=0, 0, 1, 150, 60, 0, 0, 65040, 0, columnNullability={1, 2, 3, 4, 5, 6, 7, 8}}} (io.debezium.connector.mysql.BinlogReader:491)
[2017-02-27 18:48:11,404] DEBUG Skipping insert row event: Event{header=EventHeaderV4{timestamp=1488201491000, eventType=EXT_WRITE_ROWS, serverId=13, headerLength=19, dataLength=89, nextPosition=46973819, flags=0}, data=WriteRowsEventData{tableId=715, includedColumns={0, 1, 2, 3, 4, 5, 6, 7, 8}, rows=[
    [5922, 113574, null, [B@619e0293, [B@50780a92, null, 2017-02-27T18:48:11, [B@4d33b1cd, 328]
]}} (io.debezium.connector.mysql.BinlogReader:537)
[2017-02-27 18:48:25,304] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1488201505000, eventType=QUERY, serverId=13, headerLength=19, dataLength=44, nextPosition=46973978, flags=8}, data=QueryEventData{threadId=150175, executionTime=59, errorCode=0, database='', sql='BEGIN'}} (io.debezium.connector.mysql.BinlogReader:435)
[2017-02-27 18:48:25,305] DEBUG Skipping update table metadata event: Event{header=EventHeaderV4{timestamp=1488201505000, eventType=TABLE_MAP, serverId=13, headerLength=19, dataLength=58, nextPosition=46974055, flags=0}, data=TableMapEventData{tableId=715, database='NextServices', table='SESSION', columnTypes=8, 8, 16, 15, 15, 18, 18, -2, 8, columnMetadata=0, 0, 1, 150, 60, 0, 0, 65040, 0, columnNullability={1, 2, 3, 4, 5, 6, 7, 8}}} (io.debezium.connector.mysql.BinlogReader:491)
[2017-02-27 18:48:25,305] DEBUG Skipping insert row event: Event{header=EventHeaderV4{timestamp=1488201505000, eventType=EXT_WRITE_ROWS, serverId=13, headerLength=19, dataLength=89, nextPosition=46974163, flags=0}, data=WriteRowsEventData{tableId=715, includedColumns={0, 1, 2, 3, 4, 5, 6, 7, 8}, rows=[
    [5923, 1, null, [B@34908fcf, [B@258b8954, null, 2017-02-27T18:48:25, [B@35373bed, 2]
]}} (io.debezium.connector.mysql.BinlogReader:537)
[2017-02-27 18:49:46,655] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1488201586000, eventType=QUERY, serverId=13, headerLength=19, dataLength=88, nextPosition=46974366, flags=0}, data=QueryEventData{threadId=173692, executionTime=59, errorCode=0, database='NextErpQa', sql='DROP PROCEDURE find_par'}} (io.debezium.connector.mysql.BinlogReader:435)
[2017-02-27 18:49:47,688] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1488201587000, eventType=QUERY, serverId=13, headerLength=19, dataLength=1737, nextPosition=46976187, flags=0}, data=QueryEventData{threadId=173692, executionTime=59, errorCode=0, database='NextErpQa', sql='CREATE DEFINER=`parasshah`@`%` PROCEDURE `find_par`(seed INT)
BEGIN
	
	DECLARE i int default 0;
	
	 DROP TABLE IF EXISTS _result;
	
	 CREATE TEMPORARY TABLE _result (node int primary key,id int,type varchar(20));
	
	 INSERT INTO _result(node,id,type) VALUES(seed,i,'exam');
	
	 DROP TABLE IF EXISTS _tmp;
	
	CREATE TEMPORARY TABLE _tmp (parent_node int,child_node int);
	REPEAT
	TRUNCATE TABLE _tmp;
	INSERT INTO _tmp SELECT EM.PARENT_EXAM_ID as parent_node, _result.node as child_node
	FROM _result JOIN EXAM_MAPPING EM ON EM.CHILD_EXAM_ID = _result.node;  	 
	
	INSERT IGNORE INTO _result(node,id,type) values ((SELECT parent_node FROM _tmp),i+1,'exam' );	
	
	
	
	UNTIL ROW_COUNT() = 0
	END REPEAT;
	
	select max(id) from _result into i;
	
	REPEAT
	TRUNCATE TABLE _tmp;
	
	INSERT INTO _tmp SELECT EM.EXAM_STRUCTURE_ID as parent_node, _result.node as child_node
	FROM _result JOIN EXAM_STRUCTURE_EXAM_MAPPING EM ON EM.EXAM_ID = _result.node and _result.id = i;  
	
	INSERT IGNORE INTO _result(node,id,type) values ((SELECT parent_node FROM _tmp),i+1,'exam_structure');
	
	UNTIL ROW_COUNT() = 0
	END REPEAT;
	
	select max(id) from _result into i;
	
	REPEAT
	TRUNCATE TABLE _tmp;
	
	INSERT INTO _tmp SELECT EM.PARENT_EXAM_STRUCTURE_ID as parent_node, _result.node as child_node
	FROM _result JOIN EXAM_STRUCTURE_MAPPING EM ON EM.CHILD_EXAM_STRUCTURE_ID = _result.node and _result.id = i;  

	if exists (select * from _tmp)	then	
	INSERT IGNORE INTO _result(node,id,type) values ((SELECT parent_node FROM _tmp),i+1,'exam_structure');
	end if;
	
	UNTIL ROW_COUNT() = 0
	END REPEAT;
	

	
	TRUNCATE TABLE _tmp;
	
	SELECT * FROM _result;
	
	
	DROP TABLE _tmp;
	
END'}} (io.debezium.connector.mysql.BinlogReader:435)
[2017-02-27 18:49:47,689] ERROR Error parsing DDL statement and updating tables: CREATE DEFINER=`parasshah`@`%` PROCEDURE `find_par`(seed INT)
BEGIN
	
	DECLARE i int default 0;
	
	 DROP TABLE IF EXISTS _result;
	
	 CREATE TEMPORARY TABLE _result (node int primary key,id int,type varchar(20));
	
	 INSERT INTO _result(node,id,type) VALUES(seed,i,'exam');
	
	 DROP TABLE IF EXISTS _tmp;
	
	CREATE TEMPORARY TABLE _tmp (parent_node int,child_node int);
	REPEAT
	TRUNCATE TABLE _tmp;
	INSERT INTO _tmp SELECT EM.PARENT_EXAM_ID as parent_node, _result.node as child_node
	FROM _result JOIN EXAM_MAPPING EM ON EM.CHILD_EXAM_ID = _result.node;  	 
	
	INSERT IGNORE INTO _result(node,id,type) values ((SELECT parent_node FROM _tmp),i+1,'exam' );	
	
	
	
	UNTIL ROW_COUNT() = 0
	END REPEAT;
	
	select max(id) from _result into i;
	
	REPEAT
	TRUNCATE TABLE _tmp;
	
	INSERT INTO _tmp SELECT EM.EXAM_STRUCTURE_ID as parent_node, _result.node as child_node
	FROM _result JOIN EXAM_STRUCTURE_EXAM_MAPPING EM ON EM.EXAM_ID = _result.node and _result.id = i;  
	
	INSERT IGNORE INTO _result(node,id,type) values ((SELECT parent_node FROM _tmp),i+1,'exam_structure');
	
	UNTIL ROW_COUNT() = 0
	END REPEAT;
	
	select max(id) from _result into i;
	
	REPEAT
	TRUNCATE TABLE _tmp;
	
	INSERT INTO _tmp SELECT EM.PARENT_EXAM_STRUCTURE_ID as parent_node, _result.node as child_node
	FROM _result JOIN EXAM_STRUCTURE_MAPPING EM ON EM.CHILD_EXAM_STRUCTURE_ID = _result.node and _result.id = i;  

	if exists (select * from _tmp)	then	
	INSERT IGNORE INTO _result(node,id,type) values ((SELECT parent_node FROM _tmp),i+1,'exam_structure');
	end if;
	
	UNTIL ROW_COUNT() = 0
	END REPEAT;
	

	
	TRUNCATE TABLE _tmp;
	
	SELECT * FROM _result;
	
	
	DROP TABLE _tmp;
	
END (io.debezium.connector.mysql.MySqlSchema:353)
io.debezium.text.ParsingException: Expecting token type 128 at line 27, column 2 but found 'select': = 0
	END REPEAT;
	
	 ===>> select max(id) from 
	at io.debezium.text.TokenStream.consume(TokenStream.java:725)
	at io.debezium.relational.ddl.DdlParser.consumeStatement(DdlParser.java:567)
	at io.debezium.relational.ddl.DdlParser.parseUnknownStatement(DdlParser.java:375)
	at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:153)
	at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:285)
	at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:266)
	at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:351)
	at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:461)
	at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:319)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.notifyEventListeners(BinaryLogClient.java:902)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.listenForEventPackets(BinaryLogClient.java:760)
	at com.github.shyiko.mysql.binlog.BinaryLogClient.connect(BinaryLogClient.java:472)
	at com.github.shyiko.mysql.binlog.BinaryLogClient$5.run(BinaryLogClient.java:657)
	at java.lang.Thread.run(Thread.java:745)
[2017-02-27 18:49:49,830] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1488201589000, eventType=QUERY, serverId=13, headerLength=19, dataLength=131, nextPosition=46976402, flags=0}, data=QueryEventData{threadId=173692, executionTime=59, errorCode=0, database='NextErpQa', sql='DROP TEMPORARY TABLE IF EXISTS `_result` /* generated by server */'}} (io.debezium.connector.mysql.BinlogReader:435)
[2017-02-27 18:49:50,313] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1488201590000, eventType=QUERY, serverId=13, headerLength=19, dataLength=128, nextPosition=46976614, flags=0}, data=QueryEventData{threadId=173692, executionTime=59, errorCode=0, database='NextErpQa', sql='DROP TEMPORARY TABLE IF EXISTS `_tmp` /* generated by server */'}} (io.debezium.connector.mysql.BinlogReader:435)
[2017-02-27 18:49:50,872] DEBUG Received query command: Event{header=EventHeaderV4{timestamp=1488201590000, eventType=QUERY, serverId=13, headerLength=19, dataLength=128, nextPosition=46976826, flags=0}, data=QueryEventData{threadId=173692, executionTime=59, errorCode=0, database='NextErpQa', sql='DROP TEMPORARY TABLE IF EXISTS `_tmp` /* generated by server */'}} (io.debezium.connector.mysql.BinlogReader:435)
Killed