使用flink1.17.2读取Doris2.1.2版本报错IllegalArgumentException: FLINK type is DATETIMEV2, but arrow type is TIMESTAMPMICRO.

Viewed 10

使用Flink1.17.2读取Doris2.1.2版本的集群数据,写入另一个2.1.0版本的Doris集群,Flink任务一直运行中但是无数据写入。
查看TaskManager日志:

2024-09-19 10:39:29,970 ERROR org.apache.doris.flink.serialization.RowBatch                [] - Read Doris Data failed because: 
java.lang.IllegalArgumentException: FLINK type is DATETIMEV2, but arrow type is TIMESTAMPMICRO.
	at org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:138) ~[hdgp-data-engine-bootstrap-3.5.0-SNAPSHOT.jar:?]
	at org.apache.doris.flink.serialization.RowBatch.convertArrowToRowBatch(RowBatch.java:172) ~[hdgp-data-engine-bootstrap-3.5.0-SNAPSHOT.jar:?]
	at org.apache.doris.flink.serialization.RowBatch.readArrow(RowBatch.java:135) [hdgp-data-engine-bootstrap-3.5.0-SNAPSHOT.jar:?]
	at org.apache.doris.flink.source.reader.DorisValueReader$1.run(DorisValueReader.java:176) [hdgp-data-engine-bootstrap-3.5.0-SNAPSHOT.jar:?]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_201]
2024-09-19 10:39:29,975 ERROR org.apache.flink.runtime.util.ClusterUncaughtExceptionHandler [] - WARNING: Thread 'Thread-7' produced an uncaught exception. If you want to fail on uncaught exceptions, then configure cluster.uncaught-exception-handling accordingly
org.apache.doris.flink.exception.DorisRuntimeException: FLINK type is DATETIMEV2, but arrow type is TIMESTAMPMICRO.
	at org.apache.doris.flink.serialization.RowBatch.readArrow(RowBatch.java:141) ~[hdgp-data-engine-bootstrap-3.5.0-SNAPSHOT.jar:?]
	at org.apache.doris.flink.source.reader.DorisValueReader$1.run(DorisValueReader.java:176) ~[hdgp-data-engine-bootstrap-3.5.0-SNAPSHOT.jar:?]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_201]
1 Answers

doris flink connector是哪个版本呢?用最新的connector试试的connector