2017-10-26 13:15:55,604 DEBUG MySQL|next_msr|binlog Received query command: Event{header=EventHeaderV4{timestamp=1509002448000, eventType=QUERY, serverId=13, headerLength=19, dataLength=79, nextPosition=94801224, flags=0}, data=QueryEventData{threadId=582624, executionTime=3, errorCode=0, database='DBA', sql='truncate table DAILY_DB_ACTIVITY'}} [io.debezium.connector.mysql.BinlogReader] 2017-10-26 13:15:55,610 DEBUG MySQL|next_msr|binlog Recorded DDL statements for database 'DBA': truncate table DAILY_DB_ACTIVITY [io.debezium.connector.mysql.BinlogReader] 2017-10-26 13:15:55,749 DEBUG MySQL|next_msr|binlog Received query command: Event{header=EventHeaderV4{timestamp=1509002472000, eventType=QUERY, serverId=13, headerLength=19, dataLength=88, nextPosition=94801396, flags=0}, data=QueryEventData{threadId=582624, executionTime=0, errorCode=0, database='DBA', sql='drop procedure DAILY_DB_ACTIVITY_SP'}} [io.debezium.connector.mysql.BinlogReader] 2017-10-26 13:15:55,749 DEBUG MySQL|next_msr|binlog Recorded DDL statements for database 'DBA': drop procedure DAILY_DB_ACTIVITY_SP [io.debezium.connector.mysql.BinlogReader] 2017-10-26 13:15:55,751 DEBUG MySQL|next_msr|binlog Received query command: Event{header=EventHeaderV4{timestamp=1509002477000, eventType=QUERY, serverId=13, headerLength=19, dataLength=3720, nextPosition=94805200, flags=0}, data=QueryEventData{threadId=582624, executionTime=0, errorCode=0, database='DBA', sql='CREATE DEFINER=`vazim`@`%` PROCEDURE `DAILY_DB_ACTIVITY_SP`() BEGIN set @Com_select = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_select'); set @Com_insert = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_insert'); set @Com_insert_select = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_insert_select'); set @Com_update = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_update'); set @Com_update_multi = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_update_multi'); set @Com_delete = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_delete'); set @Com_delete_multi = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_delete_multi'); set @Com_Questions = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Questions'); set @Com_Queries = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Queries'); set @Com_commit = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_commit'); set @Com_rollback = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_rollback'); set @Com_call_procedure = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_call_procedure'); set @Created_tmp_disk_tables = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Created_tmp_disk_tables'); set @Created_tmp_files = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Created_tmp_files'); set @Created_tmp_tables = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Created_tmp_tables'); set @Bytes_received = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Bytes_received'); set @Bytes_sent = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Bytes_sent'); set @Slow_queries = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Slow_queries'); set @Max_used_connections = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Max_used_connections'); INSERT INTO DAILY_DB_ACTIVITY(`SERVER`,`CREATED_ON`, `Com_select`,`Com_insert`,`Com_insert_select`,`Com_update` ,`Com_update_multi`,`Com_delete`,`Com_delete_multi`,`Com_Questions`, `Com_Queries`,`Com_commit`,`Com_rollback`,`Com_call_procedure`,`Created_tmp_disk_tables`,`Created_tmp_files`, `Created_tmp_tables`, `Bytes_received`, `Bytes_sent`,`Slow_queries`,`Max_used_connections`) VALUES('MSR_NLP',now(),@Com_select, @Com_insert, @Com_insert_select, @Com_update, @Com_update_multi, @Com_delete, @Com_delete_multi, @Com_Questions, @Com_Queries, @Com_commit, @Com_rollback, @Com_call_procedure, @Created_tmp_disk_tables, @Created_tmp_files, @Created_tmp_tables, @Bytes_received, @Bytes_sent, @Slow_queries, @Max_used_connections); update DAILY_DB_ACTIVITY set FROM_DATE=DATE(CREATED_ON) WHERE FROM_DATE is NULL; update DAILY_DB_ACTIVITY set TO_DATE=DATE_ADD(DATE(CREATED_ON), INTERVAL 1 DAY); UPDATE DAILY_DB_ACTIVITY set UP_TIME=(select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Uptime') where UP_TIME is NULL; END'}} [io.debezium.connector.mysql.BinlogReader] 2017-10-26 13:15:55,752 DEBUG MySQL|next_msr|binlog Recorded DDL statements for database 'DBA': CREATE DEFINER=`vazim`@`%` PROCEDURE `DAILY_DB_ACTIVITY_SP`() BEGIN set @Com_select = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_select'); set @Com_insert = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_insert'); set @Com_insert_select = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_insert_select'); set @Com_update = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_update'); set @Com_update_multi = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_update_multi'); set @Com_delete = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_delete'); set @Com_delete_multi = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_delete_multi'); set @Com_Questions = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Questions'); set @Com_Queries = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Queries'); set @Com_commit = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_commit'); set @Com_rollback = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_rollback'); set @Com_call_procedure = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Com_call_procedure'); set @Created_tmp_disk_tables = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Created_tmp_disk_tables'); set @Created_tmp_files = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Created_tmp_files'); set @Created_tmp_tables = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Created_tmp_tables'); set @Bytes_received = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Bytes_received'); set @Bytes_sent = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Bytes_sent'); set @Slow_queries = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Slow_queries'); set @Max_used_connections = (select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Max_used_connections'); INSERT INTO DAILY_DB_ACTIVITY(`SERVER`,`CREATED_ON`, `Com_select`,`Com_insert`,`Com_insert_select`,`Com_update` ,`Com_update_multi`,`Com_delete`,`Com_delete_multi`,`Com_Questions`, `Com_Queries`,`Com_commit`,`Com_rollback`,`Com_call_procedure`,`Created_tmp_disk_tables`,`Created_tmp_files`, `Created_tmp_tables`, `Bytes_received`, `Bytes_sent`,`Slow_queries`,`Max_used_connections`) VALUES('MSR_NLP',now(),@Com_select, @Com_insert, @Com_insert_select, @Com_update, @Com_update_multi, @Com_delete, @Com_delete_multi, @Com_Questions, @Com_Queries, @Com_commit, @Com_rollback, @Com_call_procedure, @Created_tmp_disk_tables, @Created_tmp_files, @Created_tmp_tables, @Bytes_received, @Bytes_sent, @Slow_queries, @Max_used_connections); update DAILY_DB_ACTIVITY set FROM_DATE=DATE(CREATED_ON) WHERE FROM_DATE is NULL; update DAILY_DB_ACTIVITY set TO_DATE=DATE_ADD(DATE(CREATED_ON), INTERVAL 1 DAY); UPDATE DAILY_DB_ACTIVITY set UP_TIME=(select VARIABLE_VALUE from information_schema.GLOBAL_STATUS where VARIABLE_NAME = 'Uptime') where UP_TIME is NULL; END [io.debezium.connector.mysql.BinlogReader] 2017-10-26 13:15:55,754 DEBUG MySQL|next_msr|binlog Received query command: Event{header=EventHeaderV4{timestamp=1509002497000, eventType=QUERY, serverId=13, headerLength=19, dataLength=5762, nextPosition=94811046, flags=0}, data=QueryEventData{threadId=582624, executionTime=0, errorCode=0, database='DBA', sql='CREATE DEFINER=`vazim`@`%` PROCEDURE `GET_DAILY_DB_ACTIVITY_REPORT`(IN date_from date,IN date_latest date) BEGIN IF(date_latest is NULL) THEN IF( select (UP_TIME/60/60/24) FROM DAILY_DB_ACTIVITY where FROM_DATE=(SELECT DATE_ADD(date_from, INTERVAL 1 DAY)) ) < 1 THEN SELECT DATE(d1.FROM_DATE) as DATE, (d2.Com_select) AS Com_select, (d2.Com_insert) AS Com_insert, (d2.Com_insert_select) AS Com_insert_select, (d2.Com_update) AS Com_update, (d2.Com_update_multi) AS Com_update_multi, (d2.Com_delete ) AS Com_delete, (d2.Com_delete_multi ) AS Com_delete_multi, (d2.Com_Questions ) AS Com_Questions, (d2.Com_Queries ) AS Com_Queries, (d2.Com_commit) AS Com_commit, (d2.Com_rollback) AS Com_rollback, (d2.Com_call_procedure) AS Com_call_procedure, (d2.Created_tmp_disk_tables) AS Created_tmp_disk_tables, (d2.Created_tmp_files ) AS Created_tmp_files, (d2.Created_tmp_tables) AS Created_tmp_tables, (d2.Bytes_received ) AS Bytes_received, (d2.Bytes_sent) AS Bytes_sent, (d2.Slow_queries) AS SLOW_QUERIES, (d2.Max_used_connections - 0) AS MAX_USED_CONNECTIONS from DAILY_DB_ACTIVITY d1, DAILY_DB_ACTIVITY d2 where d1.FROM_DATE=date_from and d2.FROM_DATE=DATE_ADD(date_from, INTERVAL 1 DAY); SELECT CONCAT("THE SERVER WAS RESTARTED AND HAD BEEN UP FOR ", ROUND(UP_TIME/60/60,2) ," HOURS ON ",(SELECT FROM_DATE FROM DAILY_DB_ACTIVITY WHERE FROM_DATE=date_from), ". HENCE, THE REPORT SHOWS MYSQL QUERY PARAMETERS SINCE THE SERVER RESTARTED ONLY. ") AS `SERVER RESTART INFORMATION` FROM DAILY_DB_ACTIVITY where (FROM_DATE=(SELECT DATE_ADD(date_from, INTERVAL 1 DAY))) ; ELSEIF ( select (UP_TIME/60/60/24) FROM DAILY_DB_ACTIVITY where FROM_DATE=(SELECT DATE_ADD(date_from, INTERVAL 1 DAY)) ) >= 1 THEN SELECT DATE(d1.FROM_DATE) as DATE, (d2.Com_select-d1.Com_select) AS Com_select, (d2.Com_insert - d1.Com_insert) AS Com_insert, (d2.Com_insert_select - d1.Com_insert_select) AS Com_insert_select, (d2.Com_update - d1.Com_update) AS Com_update, (d2.Com_update_multi - d1.Com_update_multi) AS Com_update_multi, (d2.Com_delete - d1.Com_delete) AS Com_delete, (d2.Com_delete_multi - d1.Com_delete_multi) AS Com_delete_multi, (d2.Com_Questions - d1.Com_Questions) AS Com_Questions, (d2.Com_Queries - d1.Com_Queries ) AS Com_Queries, (d2.Com_commit - d1.Com_commit ) AS Com_commit, (d2.Com_rollback - d1.Com_rollback) AS Com_rollback, (d2.Com_call_procedure - d1.Com_call_procedure) AS Com_call_procedure, (d2.Created_tmp_disk_tables - d1.Created_tmp_disk_tables) AS Created_tmp_disk_tables, (d2.Created_tmp_files - d1.Created_tmp_files) AS Created_tmp_files, (d2.Created_tmp_tables - d1.Created_tmp_tables) AS Created_tmp_tables, (d2.Bytes_received - d1.Bytes_received) AS Bytes_received, (d2.Bytes_sent - d1.Bytes_sent) AS Bytes_sent, (d2.Slow_queries - d1.Slow_queries) AS SLOW_QUERIES, (d2.Max_used_connections - 0) AS MAX_USED_CONNECTIONS from DAILY_DB_ACTIVITY d1, DAILY_DB_ACTIVITY d2 where d1.FROM_DATE=date_from and d2.FROM_DATE=DATE_ADD(date_from, INTERVAL 1 DAY); END IF; ELSEIF(date_latest is NOT NULL) THEN SELECT DATE(d1.FROM_DATE) as DATE, (d2.Com_select) AS Com_select, (d2.Com_insert ) AS Com_insert, (d2.Com_insert_select) AS Com_insert_select, (d2.Com_update) AS Com_update, (d2.Com_update_multi) AS Com_update_multi, (d2.Com_delete) AS Com_delete, (d2.Com_delete_multi) AS Com_delete_multi, (d2.Com_Questions) AS Com_Questions, (d2.Com_Queries ) AS Com_Queries, (d2.Com_commit ) AS Com_commit, (d2.Com_rollback) AS Com_rollback, (d2.Com_call_procedure ) AS Com_call_procedure, (d2.Created_tmp_disk_tables ) AS Created_tmp_disk_tables, (d2.Created_tmp_files) AS Created_tmp_files, (d2.Created_tmp_tables) AS Created_tmp_tables, (d2.Bytes_received) AS Bytes_received, (d2.Bytes_sent) AS Bytes_sent, (d2.Slow_queries) AS SLOW_QUERIES, (d2.Max_used_connections - 0) AS MAX_USED_CONNECTIONS from DAILY_DB_ACTIVITY d1 JOIN DAILY_DB_ACTIVITY d2 ON d2.FROM_DATE=d1.TO_DATE WHERE (d1.FROM_DATE BETWEEN date_from AND date_latest) AND (d2.UP_TIME/60/60/24 < 1) ; SELECT CONCAT("THE SERVER WAS RESTARTED AND HAD BEEN UP FOR ", ROUND(d2.UP_TIME/60/60,2) , " HOURS ON " , d1.FROM_DATE , ". HENCE, THE REPORT SHOWS MYSQL QUERY PARAMETERS SINCE THE SERVER RESTARTED ONLY. ") AS `SERVER RESTART INFORMATION` FROM DAILY_DB_ACTIVITY d1 JOIN DAILY_DB_ACTIVITY d2 ON d2.FROM_DATE=d1.TO_DATE WHERE (d1.FROM_DATE BETWEEN date_from AND date_latest) AND (d2.UP_TIME/60/60/24 < 1) ; SELECT DATE(d1.FROM_DATE) as DATE, (d2.Com_select-d1.Com_select) AS Com_select, (d2.Com_insert - d1.Com_insert) AS Com_insert, (d2.Com_insert_select - d1.Com_insert_select) AS Com_insert_select, (d2.Com_update - d1.Com_update) AS Com_update, (d2.Com_update_multi - d1.Com_update_multi) AS Com_update_multi, (d2.Com_delete - d1.Com_delete) AS Com_delete, (d2.Com_delete_multi - d1.Com_delete_multi) AS Com_delete_multi, (d2.Com_Questions - d1.Com_Questions) AS Com_Questions, (d2.Com_Queries - d1.Com_Queries ) AS Com_Queries, (d2.Com_commit - d1.Com_commit ) AS Com_commit, (d2.Com_rollback - d1.Com_rollback) AS Com_rollback, (d2.Com_call_procedure - d1.Com_call_procedure) AS Com_call_procedure, (d2.Created_tmp_disk_tables - d1.Created_tmp_disk_tables) AS Created_tmp_disk_tables, (d2.Created_tmp_files - d1.Created_tmp_files) AS Created_tmp_files, (d2.Created_tmp_tables - d1.Created_tmp_tables) AS Created_tmp_tables, (d2.Bytes_received - d1.Bytes_received) AS Bytes_received, (d2.Bytes_sent - d1.Bytes_sent) AS Bytes_sent, (d2.Slow_queries - d1.Slow_queries) AS SLOW_QUERIES, (d2.Max_used_connections - 0) AS MAX_USED_CONNECTIONS from DAILY_DB_ACTIVITY d1 JOIN DAILY_DB_ACTIVITY d2 ON d2.FROM_DATE=d1.TO_DATE WHERE (d1.FROM_DATE BETWEEN date_from AND date_latest) AND (d2.UP_TIME/60/60/24 >= 1) ; END IF; END'}} [io.debezium.connector.mysql.BinlogReader] 2017-10-26 13:15:55,756 ERROR MySQL|next_msr|binlog Error parsing DDL statement and updating tables: CREATE DEFINER=`vazim`@`%` PROCEDURE `GET_DAILY_DB_ACTIVITY_REPORT`(IN date_from date,IN date_latest date) BEGIN IF(date_latest is NULL) THEN IF( select (UP_TIME/60/60/24) FROM DAILY_DB_ACTIVITY where FROM_DATE=(SELECT DATE_ADD(date_from, INTERVAL 1 DAY)) ) < 1 THEN SELECT DATE(d1.FROM_DATE) as DATE, (d2.Com_select) AS Com_select, (d2.Com_insert) AS Com_insert, (d2.Com_insert_select) AS Com_insert_select, (d2.Com_update) AS Com_update, (d2.Com_update_multi) AS Com_update_multi, (d2.Com_delete ) AS Com_delete, (d2.Com_delete_multi ) AS Com_delete_multi, (d2.Com_Questions ) AS Com_Questions, (d2.Com_Queries ) AS Com_Queries, (d2.Com_commit) AS Com_commit, (d2.Com_rollback) AS Com_rollback, (d2.Com_call_procedure) AS Com_call_procedure, (d2.Created_tmp_disk_tables) AS Created_tmp_disk_tables, (d2.Created_tmp_files ) AS Created_tmp_files, (d2.Created_tmp_tables) AS Created_tmp_tables, (d2.Bytes_received ) AS Bytes_received, (d2.Bytes_sent) AS Bytes_sent, (d2.Slow_queries) AS SLOW_QUERIES, (d2.Max_used_connections - 0) AS MAX_USED_CONNECTIONS from DAILY_DB_ACTIVITY d1, DAILY_DB_ACTIVITY d2 where d1.FROM_DATE=date_from and d2.FROM_DATE=DATE_ADD(date_from, INTERVAL 1 DAY); SELECT CONCAT("THE SERVER WAS RESTARTED AND HAD BEEN UP FOR ", ROUND(UP_TIME/60/60,2) ," HOURS ON ",(SELECT FROM_DATE FROM DAILY_DB_ACTIVITY WHERE FROM_DATE=date_from), ". HENCE, THE REPORT SHOWS MYSQL QUERY PARAMETERS SINCE THE SERVER RESTARTED ONLY. ") AS `SERVER RESTART INFORMATION` FROM DAILY_DB_ACTIVITY where (FROM_DATE=(SELECT DATE_ADD(date_from, INTERVAL 1 DAY))) ; ELSEIF ( select (UP_TIME/60/60/24) FROM DAILY_DB_ACTIVITY where FROM_DATE=(SELECT DATE_ADD(date_from, INTERVAL 1 DAY)) ) >= 1 THEN SELECT DATE(d1.FROM_DATE) as DATE, (d2.Com_select-d1.Com_select) AS Com_select, (d2.Com_insert - d1.Com_insert) AS Com_insert, (d2.Com_insert_select - d1.Com_insert_select) AS Com_insert_select, (d2.Com_update - d1.Com_update) AS Com_update, (d2.Com_update_multi - d1.Com_update_multi) AS Com_update_multi, (d2.Com_delete - d1.Com_delete) AS Com_delete, (d2.Com_delete_multi - d1.Com_delete_multi) AS Com_delete_multi, (d2.Com_Questions - d1.Com_Questions) AS Com_Questions, (d2.Com_Queries - d1.Com_Queries ) AS Com_Queries, (d2.Com_commit - d1.Com_commit ) AS Com_commit, (d2.Com_rollback - d1.Com_rollback) AS Com_rollback, (d2.Com_call_procedure - d1.Com_call_procedure) AS Com_call_procedure, (d2.Created_tmp_disk_tables - d1.Created_tmp_disk_tables) AS Created_tmp_disk_tables, (d2.Created_tmp_files - d1.Created_tmp_files) AS Created_tmp_files, (d2.Created_tmp_tables - d1.Created_tmp_tables) AS Created_tmp_tables, (d2.Bytes_received - d1.Bytes_received) AS Bytes_received, (d2.Bytes_sent - d1.Bytes_sent) AS Bytes_sent, (d2.Slow_queries - d1.Slow_queries) AS SLOW_QUERIES, (d2.Max_used_connections - 0) AS MAX_USED_CONNECTIONS from DAILY_DB_ACTIVITY d1, DAILY_DB_ACTIVITY d2 where d1.FROM_DATE=date_from and d2.FROM_DATE=DATE_ADD(date_from, INTERVAL 1 DAY); END IF; ELSEIF(date_latest is NOT NULL) THEN SELECT DATE(d1.FROM_DATE) as DATE, (d2.Com_select) AS Com_select, (d2.Com_insert ) AS Com_insert, (d2.Com_insert_select) AS Com_insert_select, (d2.Com_update) AS Com_update, (d2.Com_update_multi) AS Com_update_multi, (d2.Com_delete) AS Com_delete, (d2.Com_delete_multi) AS Com_delete_multi, (d2.Com_Questions) AS Com_Questions, (d2.Com_Queries ) AS Com_Queries, (d2.Com_commit ) AS Com_commit, (d2.Com_rollback) AS Com_rollback, (d2.Com_call_procedure ) AS Com_call_procedure, (d2.Created_tmp_disk_tables ) AS Created_tmp_disk_tables, (d2.Created_tmp_files) AS Created_tmp_files, (d2.Created_tmp_tables) AS Created_tmp_tables, (d2.Bytes_received) AS Bytes_received, (d2.Bytes_sent) AS Bytes_sent, (d2.Slow_queries) AS SLOW_QUERIES, (d2.Max_used_connections - 0) AS MAX_USED_CONNECTIONS from DAILY_DB_ACTIVITY d1 JOIN DAILY_DB_ACTIVITY d2 ON d2.FROM_DATE=d1.TO_DATE WHERE (d1.FROM_DATE BETWEEN date_from AND date_latest) AND (d2.UP_TIME/60/60/24 < 1) ; SELECT CONCAT("THE SERVER WAS RESTARTED AND HAD BEEN UP FOR ", ROUND(d2.UP_TIME/60/60,2) , " HOURS ON " , d1.FROM_DATE , ". HENCE, THE REPORT SHOWS MYSQL QUERY PARAMETERS SINCE THE SERVER RESTARTED ONLY. ") AS `SERVER RESTART INFORMATION` FROM DAILY_DB_ACTIVITY d1 JOIN DAILY_DB_ACTIVITY d2 ON d2.FROM_DATE=d1.TO_DATE WHERE (d1.FROM_DATE BETWEEN date_from AND date_latest) AND (d2.UP_TIME/60/60/24 < 1) ; SELECT DATE(d1.FROM_DATE) as DATE, (d2.Com_select-d1.Com_select) AS Com_select, (d2.Com_insert - d1.Com_insert) AS Com_insert, (d2.Com_insert_select - d1.Com_insert_select) AS Com_insert_select, (d2.Com_update - d1.Com_update) AS Com_update, (d2.Com_update_multi - d1.Com_update_multi) AS Com_update_multi, (d2.Com_delete - d1.Com_delete) AS Com_delete, (d2.Com_delete_multi - d1.Com_delete_multi) AS Com_delete_multi, (d2.Com_Questions - d1.Com_Questions) AS Com_Questions, (d2.Com_Queries - d1.Com_Queries ) AS Com_Queries, (d2.Com_commit - d1.Com_commit ) AS Com_commit, (d2.Com_rollback - d1.Com_rollback) AS Com_rollback, (d2.Com_call_procedure - d1.Com_call_procedure) AS Com_call_procedure, (d2.Created_tmp_disk_tables - d1.Created_tmp_disk_tables) AS Created_tmp_disk_tables, (d2.Created_tmp_files - d1.Created_tmp_files) AS Created_tmp_files, (d2.Created_tmp_tables - d1.Created_tmp_tables) AS Created_tmp_tables, (d2.Bytes_received - d1.Bytes_received) AS Bytes_received, (d2.Bytes_sent - d1.Bytes_sent) AS Bytes_sent, (d2.Slow_queries - d1.Slow_queries) AS SLOW_QUERIES, (d2.Max_used_connections - 0) AS MAX_USED_CONNECTIONS from DAILY_DB_ACTIVITY d1 JOIN DAILY_DB_ACTIVITY d2 ON d2.FROM_DATE=d1.TO_DATE WHERE (d1.FROM_DATE BETWEEN date_from AND date_latest) AND (d2.UP_TIME/60/60/24 >= 1) ; END IF; END [io.debezium.connector.mysql.MySqlSchema] 2017-10-26 13:15:55,756 DEBUG MySQL|next_msr|binlog Recorded DDL statements for database 'DBA': CREATE DEFINER=`vazim`@`%` PROCEDURE `GET_DAILY_DB_ACTIVITY_REPORT`(IN date_from date,IN date_latest date) BEGIN IF(date_latest is NULL) THEN IF( select (UP_TIME/60/60/24) FROM DAILY_DB_ACTIVITY where FROM_DATE=(SELECT DATE_ADD(date_from, INTERVAL 1 DAY)) ) < 1 THEN SELECT DATE(d1.FROM_DATE) as DATE, (d2.Com_select) AS Com_select, (d2.Com_insert) AS Com_insert, (d2.Com_insert_select) AS Com_insert_select, (d2.Com_update) AS Com_update, (d2.Com_update_multi) AS Com_update_multi, (d2.Com_delete ) AS Com_delete, (d2.Com_delete_multi ) AS Com_delete_multi, (d2.Com_Questions ) AS Com_Questions, (d2.Com_Queries ) AS Com_Queries, (d2.Com_commit) AS Com_commit, (d2.Com_rollback) AS Com_rollback, (d2.Com_call_procedure) AS Com_call_procedure, (d2.Created_tmp_disk_tables) AS Created_tmp_disk_tables, (d2.Created_tmp_files ) AS Created_tmp_files, (d2.Created_tmp_tables) AS Created_tmp_tables, (d2.Bytes_received ) AS Bytes_received, (d2.Bytes_sent) AS Bytes_sent, (d2.Slow_queries) AS SLOW_QUERIES, (d2.Max_used_connections - 0) AS MAX_USED_CONNECTIONS from DAILY_DB_ACTIVITY d1, DAILY_DB_ACTIVITY d2 where d1.FROM_DATE=date_from and d2.FROM_DATE=DATE_ADD(date_from, INTERVAL 1 DAY); SELECT CONCAT("THE SERVER WAS RESTARTED AND HAD BEEN UP FOR ", ROUND(UP_TIME/60/60,2) ," HOURS ON ",(SELECT FROM_DATE FROM DAILY_DB_ACTIVITY WHERE FROM_DATE=date_from), ". HENCE, THE REPORT SHOWS MYSQL QUERY PARAMETERS SINCE THE SERVER RESTARTED ONLY. ") AS `SERVER RESTART INFORMATION` FROM DAILY_DB_ACTIVITY where (FROM_DATE=(SELECT DATE_ADD(date_from, INTERVAL 1 DAY))) ; ELSEIF ( select (UP_TIME/60/60/24) FROM DAILY_DB_ACTIVITY where FROM_DATE=(SELECT DATE_ADD(date_from, INTERVAL 1 DAY)) ) >= 1 THEN SELECT DATE(d1.FROM_DATE) as DATE, (d2.Com_select-d1.Com_select) AS Com_select, (d2.Com_insert - d1.Com_insert) AS Com_insert, (d2.Com_insert_select - d1.Com_insert_select) AS Com_insert_select, (d2.Com_update - d1.Com_update) AS Com_update, (d2.Com_update_multi - d1.Com_update_multi) AS Com_update_multi, (d2.Com_delete - d1.Com_delete) AS Com_delete, (d2.Com_delete_multi - d1.Com_delete_multi) AS Com_delete_multi, (d2.Com_Questions - d1.Com_Questions) AS Com_Questions, (d2.Com_Queries - d1.Com_Queries ) AS Com_Queries, (d2.Com_commit - d1.Com_commit ) AS Com_commit, (d2.Com_rollback - d1.Com_rollback) AS Com_rollback, (d2.Com_call_procedure - d1.Com_call_procedure) AS Com_call_procedure, (d2.Created_tmp_disk_tables - d1.Created_tmp_disk_tables) AS Created_tmp_disk_tables, (d2.Created_tmp_files - d1.Created_tmp_files) AS Created_tmp_files, (d2.Created_tmp_tables - d1.Created_tmp_tables) AS Created_tmp_tables, (d2.Bytes_received - d1.Bytes_received) AS Bytes_received, (d2.Bytes_sent - d1.Bytes_sent) AS Bytes_sent, (d2.Slow_queries - d1.Slow_queries) AS SLOW_QUERIES, (d2.Max_used_connections - 0) AS MAX_USED_CONNECTIONS from DAILY_DB_ACTIVITY d1, DAILY_DB_ACTIVITY d2 where d1.FROM_DATE=date_from and d2.FROM_DATE=DATE_ADD(date_from, INTERVAL 1 DAY); END IF; ELSEIF(date_latest is NOT NULL) THEN SELECT DATE(d1.FROM_DATE) as DATE, (d2.Com_select) AS Com_select, (d2.Com_insert ) AS Com_insert, (d2.Com_insert_select) AS Com_insert_select, (d2.Com_update) AS Com_update, (d2.Com_update_multi) AS Com_update_multi, (d2.Com_delete) AS Com_delete, (d2.Com_delete_multi) AS Com_delete_multi, (d2.Com_Questions) AS Com_Questions, (d2.Com_Queries ) AS Com_Queries, (d2.Com_commit ) AS Com_commit, (d2.Com_rollback) AS Com_rollback, (d2.Com_call_procedure ) AS Com_call_procedure, (d2.Created_tmp_disk_tables ) AS Created_tmp_disk_tables, (d2.Created_tmp_files) AS Created_tmp_files, (d2.Created_tmp_tables) AS Created_tmp_tables, (d2.Bytes_received) AS Bytes_received, (d2.Bytes_sent) AS Bytes_sent, (d2.Slow_queries) AS SLOW_QUERIES, (d2.Max_used_connections - 0) AS MAX_USED_CONNECTIONS from DAILY_DB_ACTIVITY d1 JOIN DAILY_DB_ACTIVITY d2 ON d2.FROM_DATE=d1.TO_DATE WHERE (d1.FROM_DATE BETWEEN date_from AND date_latest) AND (d2.UP_TIME/60/60/24 < 1) ; SELECT CONCAT("THE SERVER WAS RESTARTED AND HAD BEEN UP FOR ", ROUND(d2.UP_TIME/60/60,2) , " HOURS ON " , d1.FROM_DATE , ". HENCE, THE REPORT SHOWS MYSQL QUERY PARAMETERS SINCE THE SERVER RESTARTED ONLY. ") AS `SERVER RESTART INFORMATION` FROM DAILY_DB_ACTIVITY d1 JOIN DAILY_DB_ACTIVITY d2 ON d2.FROM_DATE=d1.TO_DATE WHERE (d1.FROM_DATE BETWEEN date_from AND date_latest) AND (d2.UP_TIME/60/60/24 < 1) ; SELECT DATE(d1.FROM_DATE) as DATE, (d2.Com_select-d1.Com_select) AS Com_select, (d2.Com_insert - d1.Com_insert) AS Com_insert, (d2.Com_insert_select - d1.Com_insert_select) AS Com_insert_select, (d2.Com_update - d1.Com_update) AS Com_update, (d2.Com_update_multi - d1.Com_update_multi) AS Com_update_multi, (d2.Com_delete - d1.Com_delete) AS Com_delete, (d2.Com_delete_multi - d1.Com_delete_multi) AS Com_delete_multi, (d2.Com_Questions - d1.Com_Questions) AS Com_Questions, (d2.Com_Queries - d1.Com_Queries ) AS Com_Queries, (d2.Com_commit - d1.Com_commit ) AS Com_commit, (d2.Com_rollback - d1.Com_rollback) AS Com_rollback, (d2.Com_call_procedure - d1.Com_call_procedure) AS Com_call_procedure, (d2.Created_tmp_disk_tables - d1.Created_tmp_disk_tables) AS Created_tmp_disk_tables, (d2.Created_tmp_files - d1.Created_tmp_files) AS Created_tmp_files, (d2.Created_tmp_tables - d1.Created_tmp_tables) AS Created_tmp_tables, (d2.Bytes_received - d1.Bytes_received) AS Bytes_received, (d2.Bytes_sent - d1.Bytes_sent) AS Bytes_sent, (d2.Slow_queries - d1.Slow_queries) AS SLOW_QUERIES, (d2.Max_used_connections - 0) AS MAX_USED_CONNECTIONS from DAILY_DB_ACTIVITY d1 JOIN DAILY_DB_ACTIVITY d2 ON d2.FROM_DATE=d1.TO_DATE WHERE (d1.FROM_DATE BETWEEN date_from AND date_latest) AND (d2.UP_TIME/60/60/24 >= 1) ; END IF; END [io.debezium.connector.mysql.BinlogReader] 2017-10-26 13:15:55,758 ERROR MySQL|next_msr|binlog Failed due to error: Error processing binlog event [io.debezium.connector.mysql.BinlogReader] org.apache.kafka.connect.errors.ConnectException: Expecting token type 128 at line 115, column 1 but found 'END': >= 1) ; END IF; ===>> END at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:164) at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:142) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:332) 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:748) Caused by: io.debezium.text.ParsingException: Expecting token type 128 at line 115, column 1 but found 'END': >= 1) ; END IF; ===>> END at io.debezium.text.TokenStream.consume(TokenStream.java:737) at io.debezium.relational.ddl.DdlParser.consumeStatement(DdlParser.java:568) at io.debezium.relational.ddl.DdlParser.parseUnknownStatement(DdlParser.java:376) at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:168) at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:286) at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:267) at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:354) at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:461) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:319) ... 5 more 2017-10-26 13:15:55,764 INFO MySQL|next_msr|binlog Error processing binlog event, and propagating to Kafka Connect so it stops this connector. Future binlog events read before connector is shutdown will be ignored. [io.debezium.connector.mysql.BinlogReader] 2017-10-26 13:15:56,376 ERROR || Task next_msr-connector-0 threw an uncaught and unrecoverable exception [org.apache.kafka.connect.runtime.WorkerTask] org.apache.kafka.connect.errors.ConnectException: Expecting token type 128 at line 115, column 1 but found 'END': >= 1) ; END IF; ===>> END at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:164) at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:142) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:332) 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:748) Caused by: io.debezium.text.ParsingException: Expecting token type 128 at line 115, column 1 but found 'END': >= 1) ; END IF; ===>> END at io.debezium.text.TokenStream.consume(TokenStream.java:737) at io.debezium.relational.ddl.DdlParser.consumeStatement(DdlParser.java:568) at io.debezium.relational.ddl.DdlParser.parseUnknownStatement(DdlParser.java:376) at io.debezium.connector.mysql.MySqlDdlParser.parseNextStatement(MySqlDdlParser.java:168) at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:286) at io.debezium.relational.ddl.DdlParser.parse(DdlParser.java:267) at io.debezium.connector.mysql.MySqlSchema.applyDdl(MySqlSchema.java:354) at io.debezium.connector.mysql.BinlogReader.handleQueryEvent(BinlogReader.java:461) at io.debezium.connector.mysql.BinlogReader.handleEvent(BinlogReader.java:319) ... 5 more 2017-10-26 13:15:56,376 ERROR || Task is being killed and will not recover until manually restarted [org.apache.kafka.connect.runtime.WorkerTask]