【Flink】FlinkSQL读取Mysql表中时间字段相差13个小时

发布时间:2024年01月19日

问题:Flink版本1.13,在我们使用FlinkSQL读取Mysql中数据的时候,发现读取出来的时间字段中的数据和Mysql表中的数据相差13个小时,Mysql建表语句及插入的数据如下;

CREATE TABLE `mysql_example` (
`id` int(11) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增ID',
`name` varchar(64) DEFAULT NULL COMMENT '姓名',
`create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
PRIMARY KEY (`id`)

COMMENT = 'mysql例子'
ENGINE = InnoDB;

insert into mysql_example values(1,'li','2024-01-01 14:06:30');

insert into mysql_example values(2,'张三','2024-01-01 14:06:30');

FlinkSQL的语句及查询出的结果如下

CREATE TABLE mysql_table (
     id BIGINT,
     name STRING,
     create_time TIMESTAMP
) WITH (
  'connector' = 'jdbc',
  'url' = '

文章来源:https://blog.csdn.net/sinat_23225111/article/details/135680135
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。