Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 8 additions & 7 deletions mysql_ch_replicator/pymysqlreplication/binlogstream.py
Original file line number Diff line number Diff line change
Expand Up @@ -310,7 +310,7 @@ def __connect_to_ctl(self):
self._ctl_connection = self.pymysql_wrapper(**self._ctl_connection_settings)
self._ctl_connection._get_dbms = self.__get_dbms
self.__connected_ctl = True
self.__check_optional_meta_data()
#self.__check_optional_meta_data()

def __checksum_enabled(self):
"""Return True if binlog-checksum = CRC32. Only for MySQL > 5.6"""
Expand Down Expand Up @@ -563,12 +563,13 @@ def __check_optional_meta_data(self):
cur.execute("SHOW VARIABLES LIKE 'BINLOG_ROW_METADATA';")
value = cur.fetchone()
if value is None: # BinLog Variable Not exist It means Not Supported Version
logging.log(
logging.WARN,
"""
Before using MARIADB 10.5.0 and MYSQL 8.0.14 versions,
use python-mysql-replication version Before 1.0 version """,
)
pass
# logging.log(
# logging.WARN,
# """
# Before using MARIADB 10.5.0 and MYSQL 8.0.14 versions,
# use python-mysql-replication version Before 1.0 version """,
# )
else:
value = value.get("Value", "")
if value.upper() != "FULL":
Expand Down
Loading