[
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)
