dinky flinkcdc 同步mysql到doris时间类型datetime入doris时间类型datetime报错
mysql 同步doris 时间类型报错
·
1、我的环境
dinky0.7.5 + flink1.17.2
flink-sql-connector-mysql-cdc-2.3.0.jar
flink-doris-connector-1.17-1.5.1.jar
2、问题现象
dinky flinkcdc 同步mysql到doris时间类型datetime入doris时间类型datetime报错：
3、解决方案
flinkcdc 将source 表datetime类型默认转换成了string，我们在创建source表时字段类型设置成timestamp，创建sink表的时候要把相关字段类型也设置成string类型，insert时通过date_format转换成需要的时间格式，doris目标表为datetime类型，成功写入。
4、写在最后
flink cdc代码调试一定要紧盯报错日志，根据报错日志内容不断的尝试修改cdc代码，这个测试了N多种组合才成功写入的。
魔乐社区（Modelers.cn) 是一个中立、公益的人工智能社区，提供人工智能工具、模型、数据的托管、展示与应用协同服务，为人工智能开发及爱好者搭建开放的学习交流平台。社区通过理事会方式运作，由全产业链共同建设、共同运营、共同享有，推动国产AI生态繁荣发展。
更多推荐
9
0- 0
已为社区贡献2条内容
所有评论(0)