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

这篇具有很好参考价值的文章主要介绍了【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' = '文章来源地址https://www.toymoban.com/news/detail-804099.html

到了这里,关于【Flink】FlinkSQL读取Mysql表中时间字段相差13个小时的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 2.3 如何使用FlinkSQL读取&写入到JDBC(MySQL)

    FlinkSQL允许使用 JDBC连接器,向任意类型的关系型数据库读取或者写入数据 添加Maven依赖 注意:如果使用 sql-client客户端,需保证 flink-1.17.1/lib 目录下 存在相应的jar包  相关jar可以通过官网下载:JDBC SQL 连接器  FlinkSQL读取MySQL表时,为批式处理,在流式计算任务中,通常被

    2024年02月06日
    浏览(33)
  • MySQL使用GROUP BY分组后,获取每组中时间记录最新的行对应的其他字段

    在编写MySQL数据库查询语句时,经常遇到使用GROUP BY分组后,需要获取每组中时间记录最新的行对应的其他字段这一情况。例如下表(t_score): id student course score examdate 1 小张 语文 89.0 2023-06-29 2 小张 数学 90.0 2023-06-29 3 小张 语文 91.0 2024-01-10 4 小张 数学 93.0 2024-01-10 5 小李 语

    2024年01月17日
    浏览(27)
  • 基于 Dinky + FlinkSQL + Flink CDC 同步 MySQL 数据到 Elasticsearch、Kafka

    Dinky 是一个开箱即用的一站式实时计算平台以 Apache Flink 为基础,连接 OLAP 和数据湖等众多框架致力于流批一体和湖仓一体的建设与实践。本文以此为FlinkSQL可视化工具。 Flink SQL 使得使用标准 SQL 开发流式应用变得简单,免去代码开发。 Flink CDC 本文使用 MySQL CDC 连接器 允许从

    2024年02月16日
    浏览(31)
  • java获取时间相差8小时的各种情况

    2024年02月22日
    浏览(21)
  • 解决服务器时间与实际时间相差8小时问题

    ​ 在实际部署项目到服务器运行时,我们通常会发现程序在服务器上执行的时间实际上时比现实时间要慢8小时的,其实这是因为本地时区和服务器的时区不一样,差了8个小时导致,那么如何去纠正8小时的时差呢?以下是我常用的解决方法 1. 在使用Jar命令启动服务时添加-Duser.ti

    2024年02月09日
    浏览(25)
  • 服务器时间与本地时间不一致(相差8小时)

    Linux服务器上获取时间总是和本地电脑windows系统时间相差8小时。 硬件时钟不与UTC时间一致问题,时区不一样所引起的。 方法一:当地时间替换为上海 方法二:环境变量/etc/profile

    2024年02月01日
    浏览(35)
  • docker容器的时间和宿主机时间不一致相差8小时

    在docker容器和系统时间不一致是因为docker容器的原生时区为0时区,而宿主机时间是+8个时区 先要确认宿主机时间是否正确 可以使用date命令 如果时间错误,则先进行对时 运行 docker run 添加 -v /etc/localtime:/etc/localtime 选项,如下: 如果统一时区还需要添加-v /etc/timezone:/etc/time

    2024年02月12日
    浏览(43)
  • 解决:Java后端返回给前端的Date格式数据相差8小时的问题

    问题描述: 后端得到的数据是对的,但是返回给前端后,数据比原数据慢了8小时。 原因: json数据在返回浏览器端是会被spring-boot默认的Jackson框架转换,而Jackson框架默认的时区GMT(相对于中国是少了8小时)。 解决: 在application.yml文件中,配置

    2024年04月16日
    浏览(30)
  • 【Flink】FlinkCDC获取mysql数据时间类型差8小时时区解决方案

    1、背景: 在我们使用FlinkCDC采集mysql数据的时候,日期类型是我们很常见的类型,但是FlinkCDC读取出来会和数据库的日期时间不一致,情况如下 FlinkCDC获取的数据中create_time字段1694597238000转换为时间戳2023-09-13 17:27:18  而数据库中原始数据如下,并没有到下午5点,这就导致了

    2024年02月07日
    浏览(33)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包