diff --git a/pymysqlreplication/binlogstream.py b/pymysqlreplication/binlogstream.py index 094a80d8..654b3b8c 100644 --- a/pymysqlreplication/binlogstream.py +++ b/pymysqlreplication/binlogstream.py @@ -565,12 +565,10 @@ def __check_optional_meta_data(self): logging.log( logging.WARN, """ - Setting The Variable Value BINLOG_ROW_METADATA = FULL + Setting The Variable Value BINLOG_ROW_METADATA = FULL, BINLOG_ROW_IMAGE = FULL. By Applying this, provide properly mapped column information on UPDATE,DELETE,INSERT. """, ) - else: - self.__optional_meta_data = True def fetchone(self): while True: diff --git a/pymysqlreplication/row_event.py b/pymysqlreplication/row_event.py index 039cb577..095275c0 100644 --- a/pymysqlreplication/row_event.py +++ b/pymysqlreplication/row_event.py @@ -71,7 +71,6 @@ def __init__(self, from_packet, event_size, table_map, ctl_connection, **kwargs) self.nbd_info_length, self.nbd_info_format = struct.unpack( "