项目场景:

Flink Sql jdbc connector 时区问题


问题描述

Flink sql jdbc读取的数据时间类型 比mysql快了 13个小时


原因分析:

时区问题导致

解决方案:

建表时url中添加serverTimezone=Asia/Shanghai

WITH (
   'connector' = 'jdbc',
   'url' = 'jdbc:mysql://xxxx:3306/xxxx?serverTimezone=Asia/Shanghai',
   'table-name' = 'xxxx',
   'username' = 'xxx',
   'password' = 'xxx'
);