flink timestamp 解析问题

你好 这边使用flink sql有如下问题；

CREATE TABLE source1 ( id BIGINT , username STRING , password STRING , AddTime TIMESTAMP , origin_table STRING METADATA FROM 'value.table' VIRTUAL ) WITH ( 'connector' = 'kafka', 'topic' = 'plink_canal', 'properties.bootstrap.servers' = '***', 'properties.group.id' = 'canal1', 'scan.startup.mode' = 'group-offsets', 'canal-json.table.include' = 'test.', 'format' = 'canal-json' );

当binlog 数据为非法日期时候。会出现如下报错 Caused by: java.time.format.DateTimeParseException: Text '0000-00-00 00:00:00' could not be parsed: Invalid value for MonthOfYear (valid values 1 - 12): 0 这个有办法解决吗。我们上游业务库 数据 就会有这样的非法日期， 谢谢回答*来自志愿者整理的flink邮件归档