FlinkCDC里这个报错意思很明确，但不想改binlog

Flink CDC报错可能是因为binlog格式不兼容，建议检查binlog格式并修改为Flink支持的格式。

报错信息：

创新互联专业为企业提供莆田网站建设、莆田做网站、莆田网站设计、莆田网站制作等企业网站建设、网页设计与制作、莆田企业网站模板建站服务，十余年莆田做网站经验，不只是建网站，更提供有价值的思路和整体网络服务。

org.apache.flink.table.api.ValidationException: The binlog reader does not support the timestamp type of the changelog table.

这个错误表示Flink CDC在读取binlog时，不支持changelog表的timestamp类型，为了解决这个问题，你可以尝试以下方法：

1、更改changelog表的timestamp类型

2、不使用binlog作为数据源

3、使用其他支持timestamp类型的binlog reader

下面详细介绍这三种方法：

更改changelog表的timestamp类型

1、修改changelog表的结构，将timestamp字段的类型更改为Flink CDC支持的类型，TIMESTAMP(3) NOT NULL。

2、重新创建changelog表。

3、重启Flink作业。

不使用binlog作为数据源

1、选择其他数据源，Kafka、MySQL等。

2、修改Flink作业的代码，使用新的数据源。

3、启动Flink作业。

使用其他支持timestamp类型的binlog reader

1、寻找其他支持timestamp类型的binlog reader，Debezium。

2、下载并配置Debezium。

3、修改Flink作业的代码，使用Debezium作为binlog reader。

4、启动Flink作业。

分享题目：FlinkCDC里这个报错意思很明确，但不想改binlog
网页路径：http://www.gawzjz.com/qtweb/news41/163991.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联