本文主要是介绍【Flink】FlinkSQL读取Mysql表中时间字段相差13个小时,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
问题: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' = '
这篇关于【Flink】FlinkSQL读取Mysql表中时间字段相差13个小时的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!