You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "coco (Jira)" <ji...@apache.org> on 2021/12/12 11:59:00 UTC
[jira] [Created] (FLINK-25264) Does the binlog_row_image of MySQL must be in full mode when Flink CDC is used?
coco created FLINK-25264:
----------------------------
Summary: Does the binlog_row_image of MySQL must be in full mode when Flink CDC is used?
Key: FLINK-25264
URL: https://issues.apache.org/jira/browse/FLINK-25264
Project: Flink
Issue Type: Bug
Components: Table SQL / API
Affects Versions: 1.13.3
Reporter: coco
Fix For: 1.13.3
When I use Flink CDC to connect to MySQL, I encounter the following problems:
Connection gracefully closed
Uncaught exception in the SplitEnumerator for Source Source: TableSourceScan(table=[[default_catalog, default_database, t_alarm_op_record_202112]], fields=[CSN, OPERATION, OPERATOR, UTCTIME, CONTENT]) while starting the SplitEnumerator.. Triggering job failover.
org.apache.flink.table.api.ValidationException: {color:#FF0000}*The MySQL server is configured with binlog_row_image MINIMAL rather than FULL, which is required for this connector to work properly. Change the MySQL configuration to use a binlog_row_image=FULL and restart the connector.*{color}
at com.ververica.cdc.connectors.mysql.MySqlValidator.checkBinlogRowImage(MySqlValidator.java:132) ~[flink-connector-mysql-cdc-2.0.0.jar:2.0.0]
...
Check the MySQL configuration.
Mysql> select @@global.binlog_row_image,@@session.binlog_row_image;
It is indeed MINIMAL.
Does the binlog_row_image of MySQL must be in full mode when Flink CDC is used?
--
This message was sent by Atlassian Jira
(v8.20.1#820001)