全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言机器学习

Flink sql报错：Unable to convert to TimestampData from unexpected value '1637681884000' of type java.la

提问者：帅平问题分类：大数据

Flink sql执行的时候报错了，提示：

java.lang.IllegalArgumentException: Unable to convert to TimestampData from unexpected value '1637681884000' of type java.lang.Long
        at com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema.convert(RowDataDebeziumDeserializeSchema.java:516) ~[flink-sql-connector-mysql-cdc-2.4.1.jar:2.4.1]
        at com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema.convert(RowDataDebeziumDeserializeSchema.java:653) ~[flink-sql-connector-mysql-cdc-2.4.1.jar:2.4.1]
        at com.ververica.cdc.debezium.table.RowDataDebeziumDeserializeSchema.convertField(RowDataDebeziumDeserializeSchema.java:638) ~[flink-sql-connector-mysql-cdc-2.4.1.jar:2.4.1]

Flink

发布于：4周前 (09-05) IP属地：四川省

1 个回答

我是蓝天i

这是因为在flink sql中，如果是外部表的话，对于时间类型来说，不能使用TIMESTAMP_LTZ，只能用TIMESTAMP

发布于：4周前 (09-05) IP属地：四川省

我来回答