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]
1 个回答
我是蓝天i
我是蓝天i
这是因为在flink sql中,如果是外部表的话,对于时间类型来说,不能使用TIMESTAMP_LTZ,只能用TIMESTAMP
发布于:10个月前 (09-05) IP属地:四川省
我来回答