使用x2doris迁移数据时提示java.lang.IllegalArgumentException: Spark type is DATETIMEV2, but arrow type is TIMESTAMPMICRO

Viewed 25

版本:selectdb-doris-2.1.1-rc05
如果没有日期字段的表迁移数据都没问题,不知道为啥一有日期字段就报这个错误了,我最开始的方案使用FLink 来迁移,当时使用DorisSourceFunction的时候 也碰到了如果要迁移的数据里面有日期类型,获取到的scheme为null,发现官网有个x2doris工具,结果用这个工具日期字段也有问题,有碰到过的兄弟吗,报错截图如下:
image.png
image.png

2 Answers

如果是flink 读取2.1.x的datatime,date数据类型,把connector升级到1.6.x

这个问题已经修了,在x2doris的1.0.5版本,暂未发版,可以加我微信(Faith_xzc),给你单独打个包