flink timestamp 解析问题

Tue, 05 Jan 2021 18:41:24 -0800 

你好 这边使用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
这个有办法解决吗。我们上游业务库 数据 就会有这样的非法日期，
谢谢回答

回复