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://bzwzjz.com/article/dhcceog.html

其他资讯

Copyright © 2007-2020 广东宝晨空调科技有限公司 All Rights Reserved 粤ICP备2022107769号
友情链接: 成都网站设计 网站制作报价 LED网站设计方案 成都网站制作 成都网站制作 重庆网站制作 营销型网站建设 企业网站设计 成都网站建设 成都品牌网站建设 攀枝花网站设计 成都企业网站制作 定制网站建设 网站制作 成都网站制作 四川成都网站设计 专业网站设计 营销网站建设 定制级高端网站建设 成都网站设计 网站建设方案 盐亭网站设计