国产 无码 综合区,色欲AV无码国产永久播放,无码天堂亚洲国产AV,国产日韩欧美女同一区二区

【Flink】FlinkSQL讀取Mysql表中時(shí)間字段相差13個(gè)小時(shí)

這篇具有很好參考價(jià)值的文章主要介紹了【Flink】FlinkSQL讀取Mysql表中時(shí)間字段相差13個(gè)小時(shí)。希望對(duì)大家有所幫助。如果存在錯(cuò)誤或未考慮完全的地方,請(qǐng)大家不吝賜教,您也可以點(diǎn)擊"舉報(bào)違法"按鈕提交疑問。

問題:Flink版本1.13,在我們使用FlinkSQL讀取Mysql中數(shù)據(jù)的時(shí)候,發(fā)現(xiàn)讀取出來的時(shí)間字段中的數(shù)據(jù)和Mysql表中的數(shù)據(jù)相差13個(gè)小時(shí),Mysql建表語(yǔ)句及插入的數(shù)據(jù)如下;

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 '創(chuàng)建時(shí)間',
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的語(yǔ)句及查詢出的結(jié)果如下

CREATE TABLE mysql_table?(
? ? ?id BIGINT,
? ? ?name STRING,
? ? ?create_time TIMESTAMP
) WITH (
? 'connector' = 'jdbc',
? 'url' = '文章來源地址http://www.zghlxwxcb.cn/news/detail-804099.html

到了這里,關(guān)于【Flink】FlinkSQL讀取Mysql表中時(shí)間字段相差13個(gè)小時(shí)的文章就介紹完了。如果您還想了解更多內(nèi)容,請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!

本文來自互聯(lián)網(wǎng)用戶投稿,該文觀點(diǎn)僅代表作者本人,不代表本站立場(chǎng)。本站僅提供信息存儲(chǔ)空間服務(wù),不擁有所有權(quán),不承擔(dān)相關(guān)法律責(zé)任。如若轉(zhuǎn)載,請(qǐng)注明出處: 如若內(nèi)容造成侵權(quán)/違法違規(guī)/事實(shí)不符,請(qǐng)點(diǎn)擊違法舉報(bào)進(jìn)行投訴反饋,一經(jīng)查實(shí),立即刪除!

領(lǐng)支付寶紅包贊助服務(wù)器費(fèi)用

相關(guān)文章

  • 2.3 如何使用FlinkSQL讀取&寫入到JDBC(MySQL)

    2.3 如何使用FlinkSQL讀取&寫入到JDBC(MySQL)

    FlinkSQL允許使用 JDBC連接器,向任意類型的關(guān)系型數(shù)據(jù)庫(kù)讀取或者寫入數(shù)據(jù) 添加Maven依賴 注意:如果使用?sql-client客戶端,需保證?flink-1.17.1/lib 目錄下 存在相應(yīng)的jar包 ?相關(guān)jar可以通過官網(wǎng)下載:JDBC SQL 連接器? FlinkSQL讀取MySQL表時(shí),為批式處理,在流式計(jì)算任務(wù)中,通常被

    2024年02月06日
    瀏覽(18)
  • MySQL使用GROUP BY分組后,獲取每組中時(shí)間記錄最新的行對(duì)應(yīng)的其他字段

    MySQL使用GROUP BY分組后,獲取每組中時(shí)間記錄最新的行對(duì)應(yīng)的其他字段

    在編寫MySQL數(shù)據(jù)庫(kù)查詢語(yǔ)句時(shí),經(jīng)常遇到使用GROUP BY分組后,需要獲取每組中時(shí)間記錄最新的行對(duì)應(yīng)的其他字段這一情況。例如下表(t_score): id student course score examdate 1 小張 語(yǔ)文 89.0 2023-06-29 2 小張 數(shù)學(xué) 90.0 2023-06-29 3 小張 語(yǔ)文 91.0 2024-01-10 4 小張 數(shù)學(xué) 93.0 2024-01-10 5 小李 語(yǔ)

    2024年01月17日
    瀏覽(22)
  • 基于 Dinky + FlinkSQL + Flink CDC 同步 MySQL 數(shù)據(jù)到 Elasticsearch、Kafka

    基于 Dinky + FlinkSQL + Flink CDC 同步 MySQL 數(shù)據(jù)到 Elasticsearch、Kafka

    Dinky 是一個(gè)開箱即用的一站式實(shí)時(shí)計(jì)算平臺(tái)以 Apache Flink 為基礎(chǔ),連接 OLAP 和數(shù)據(jù)湖等眾多框架致力于流批一體和湖倉(cāng)一體的建設(shè)與實(shí)踐。本文以此為FlinkSQL可視化工具。 Flink SQL 使得使用標(biāo)準(zhǔn) SQL 開發(fā)流式應(yīng)用變得簡(jiǎn)單,免去代碼開發(fā)。 Flink CDC 本文使用 MySQL CDC 連接器 允許從

    2024年02月16日
    瀏覽(19)
  • 解決服務(wù)器時(shí)間與實(shí)際時(shí)間相差8小時(shí)問題

    ? 在實(shí)際部署項(xiàng)目到服務(wù)器運(yùn)行時(shí),我們通常會(huì)發(fā)現(xiàn)程序在服務(wù)器上執(zhí)行的時(shí)間實(shí)際上時(shí)比現(xiàn)實(shí)時(shí)間要慢8小時(shí)的,其實(shí)這是因?yàn)楸镜貢r(shí)區(qū)和服務(wù)器的時(shí)區(qū)不一樣,差了8個(gè)小時(shí)導(dǎo)致,那么如何去糾正8小時(shí)的時(shí)差呢?以下是我常用的解決方法 1. 在使用Jar命令啟動(dòng)服務(wù)時(shí)添加-Duser.ti

    2024年02月09日
    瀏覽(21)
  • 服務(wù)器時(shí)間與本地時(shí)間不一致(相差8小時(shí))

    服務(wù)器時(shí)間與本地時(shí)間不一致(相差8小時(shí))

    Linux服務(wù)器上獲取時(shí)間總是和本地電腦windows系統(tǒng)時(shí)間相差8小時(shí)。 硬件時(shí)鐘不與UTC時(shí)間一致問題,時(shí)區(qū)不一樣所引起的。 方法一:當(dāng)?shù)貢r(shí)間替換為上海 方法二:環(huán)境變量/etc/profile

    2024年02月01日
    瀏覽(32)
  • docker容器的時(shí)間和宿主機(jī)時(shí)間不一致相差8小時(shí)

    在docker容器和系統(tǒng)時(shí)間不一致是因?yàn)閐ocker容器的原生時(shí)區(qū)為0時(shí)區(qū),而宿主機(jī)時(shí)間是+8個(gè)時(shí)區(qū) 先要確認(rèn)宿主機(jī)時(shí)間是否正確 可以使用date命令 如果時(shí)間錯(cuò)誤,則先進(jìn)行對(duì)時(shí) 運(yùn)行 docker run 添加 -v /etc/localtime:/etc/localtime 選項(xiàng),如下: 如果統(tǒng)一時(shí)區(qū)還需要添加-v /etc/timezone:/etc/time

    2024年02月12日
    瀏覽(24)
  • 解決:Java后端返回給前端的Date格式數(shù)據(jù)相差8小時(shí)的問題

    問題描述: 后端得到的數(shù)據(jù)是對(duì)的,但是返回給前端后,數(shù)據(jù)比原數(shù)據(jù)慢了8小時(shí)。 原因: json數(shù)據(jù)在返回瀏覽器端是會(huì)被spring-boot默認(rèn)的Jackson框架轉(zhuǎn)換,而Jackson框架默認(rèn)的時(shí)區(qū)GMT(相對(duì)于中國(guó)是少了8小時(shí))。 解決: 在application.yml文件中,配置

    2024年04月16日
    瀏覽(162)
  • 【Flink】FlinkCDC獲取mysql數(shù)據(jù)時(shí)間類型差8小時(shí)時(shí)區(qū)解決方案

    【Flink】FlinkCDC獲取mysql數(shù)據(jù)時(shí)間類型差8小時(shí)時(shí)區(qū)解決方案

    1、背景: 在我們使用FlinkCDC采集mysql數(shù)據(jù)的時(shí)候,日期類型是我們很常見的類型,但是FlinkCDC讀取出來會(huì)和數(shù)據(jù)庫(kù)的日期時(shí)間不一致,情況如下 FlinkCDC獲取的數(shù)據(jù)中create_time字段1694597238000轉(zhuǎn)換為時(shí)間戳2023-09-13 17:27:18 ?而數(shù)據(jù)庫(kù)中原始數(shù)據(jù)如下,并沒有到下午5點(diǎn),這就導(dǎo)致了

    2024年02月07日
    瀏覽(25)

覺得文章有用就打賞一下文章作者

支付寶掃一掃打賞

博客贊助

微信掃一掃打賞

請(qǐng)作者喝杯咖啡吧~博客贊助

支付寶掃一掃領(lǐng)取紅包,優(yōu)惠每天領(lǐng)

二維碼1

領(lǐng)取紅包

二維碼2

領(lǐng)紅包