flink timestamp 解析问题

[air23]

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

[nobleyd]

可以看下文档去，配置忽略解析错误。

air23 <[hidden email]> 于2021年1月6日周三 上午10:41写道：

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