使用flink-sql解析debezium采集的mysql timestamp字段报错

Mon, 30 Nov 2020 19:09:40 -0800 

flink-sql-client执行建表：

CREATE TABLE source_xxx (
 id INT,
 ctime TIMESTAMP
) WITH (
 'connector' = 'kafka',
 'topic' = 'xxx',
 'properties.bootstrap.servers' = 'localhost:9092',
 'format' = 'debezium-json',
 'scan.startup.mode' = 'earliest-offset',
 'debezium-json.schema-include' = 'false',
 'debezium-json.ignore-parse-errors' = 'false'
);

查询：
select * from source_xxx;
[ERROR] Could not execute SQL statement. Reason:
java.time.format.DateTimeParseException: Text '2018-07-10T23:47:35Z' could
not be parsed at index 10

mysql源表中ctime字段为timestamp类型，增加'debezium-json.timestamp-format.standard' =
'ISO-8601'配置依然报错，结尾多了个Z。
想咨询一下，这块儿是flink-sql和debezium采集的timestamp格式不兼容么？还是我debezium的配置，或者使用的flink-sql类型有问题？

回复