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。内容未经允许不得转载,或转载时需注明来源: 创新互联