[ https://issues.apache.org/jira/browse/FLINK-25264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17458544#comment-17458544 ]
Leonard Xu commented on FLINK-25264: ------------------------------------ [~coco_yiyayiya] Yes, we need MySQL works under full mode for capturing entire and consistent data change. [~MartijnVisser] Yes, user should report the issue/discussion in flink-cdc-connector project, I close this one now. [~coco_yiyayiya] Please open Flink CDC related issues in flink-cdc-connector project as it is independent with Flink project, thanks. > 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 > Priority: Major > Labels: Flink-CDC, MySQL > 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)