Caused by: org.apache.kafka.connect.errors.ConnectException: The binlog event does not contain expected number of columns; the internal schema representation is probably out of sync with the real database schema, or the binlog contains events recorded with binlog_row_image other than FULL or the table in question is an NDB table。

[yuandanhn]

读的是阿里云的mysql3.6 binlog 实, mysql库里的表，都是hibernate自动建的表;
flink-1.11.2版本，跑如截图任务时，

突然自己报这个错Caused by: org.apache.kafka.connect.errors.ConnectException: The binlog event does not contain expected number of columns; the internal schema representation is probably out of sync with the real database schema, or the binlog contains events recorded with binlog_row_image other than FULL or the table in question is an NDB table。
根据报错提示检查：binlog事件预期的列都在的；内部schema与实际数据库schema同步的；binlog_row_image配置的就是FULL；没有内存表。
之前差不多的sql任务，就是表少些，能跑的，这个每次过段时间就自己死掉了。。。请问下什么原因呢？

[yuandanhn]

以上rds数据导出到本地跑是可以的，不会突然挂掉，不知道是不是跟阿里云RDS的binlog会定时的上传到oss空间有关系

[yuandanhn]

最后查出，阿里云rds下某个表product_field_users本来只有两列，但是在binlog日志里这个表会多一列__#alibaba_rds_row_id#__加起来三列，应该是这列的原因导致结构不一致吧，不过这一列完全是多余的

[yuandanhn]

请问这个隐藏主键的问题咋处理呢，表结构和binlog的不一致

[yuandanhn]

CREATE TABLE product_field_users(
product_field_id bigint,
user_id bigint
)WITH (
'connector' = 'mysql-cdc',
'hostname' = 'rds*****.mysql.rds.aliyuncs.com',
'port' = '3306',
'username' = 'flin***6',
'password' = '***q',
'database-name' = 'soomey_net',
'table-name' = 'product_field_users',
'debezium.snapshot.mode'='schema_only',
'debezium.column.blacklist'='#alibaba_rds_row_id#'
);
如上，配置了忽略__#alibaba_rds_row_id#__，修改表数据时还是报一样的错误

[yuandanhn]

最后下载源码，改了debezium，增加针对阿里云隐藏主键判断，已经解决