真实的国产乱ⅩXXX66竹夫人,五月香六月婷婷激情综合,亚洲日本VA一区二区三区,亚洲精品一区二区三区麻豆

成都創(chuàng)新互聯(lián)網(wǎng)站制作重慶分公司

flinkmysql數(shù)據(jù)接入的方法

這篇文章主要講解了“flink MySQL數(shù)據(jù)接入的方法”，文中的講解內(nèi)容簡單清晰，易于學(xué)習(xí)與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學(xué)習(xí)“flink mysql數(shù)據(jù)接入的方法”吧！

公司主營業(yè)務(wù)：成都網(wǎng)站設(shè)計、做網(wǎng)站、移動網(wǎng)站開發(fā)等業(yè)務(wù)。幫助企業(yè)客戶真正實現(xiàn)互聯(lián)網(wǎng)宣傳，提高企業(yè)的競爭能力。創(chuàng)新互聯(lián)是一支青春激揚、勤奮敬業(yè)、活力青春激揚、勤奮敬業(yè)、活力澎湃、和諧高效的團(tuán)隊。公司秉承以“開放、自由、嚴(yán)謹(jǐn)、自律”為核心的企業(yè)文化，感謝他們對我們的高要求，感謝他們從不同領(lǐng)域給我們帶來的挑戰(zhàn)，讓我們激情的團(tuán)隊有機會用頭腦與智慧不斷的給客戶帶來驚喜。創(chuàng)新互聯(lián)推出阿魯科爾沁免費做網(wǎng)站回饋大家。

一.api方式接入

1.添加依賴

       

            com.alibaba.ververica        

            flink-connector-mysql-cdc        

                      1.1          .          0                  

       

2.API代碼

public                     static                     void                     main(String[] args)           throws                     Exception {        

              SourceFunction sourceFunction = MySQLSource.builder()        

                .hostname(          "localhost"          )        

                .port(          3306          )        

                .databaseList(          "test"          )        

                .tableList(          "test"          )        

                .deserializer(          new                     StringDebeziumDeserializationSchema())        

                .build();        

 

              StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();        

              env.addSource(sourceFunction)        

                .print().setParallelism(          1          );        

              env.execute();        

            }        

二.sql方式接入

1.添加jar包至lib下

flink-sql-connector-mysql-cdc_1.1.0.jar

2.mysql中創(chuàng)建表

create                     table                     test(        

id           INT          ,        

name                     varchar          (100),        

description           varchar          (100),        

weight           DECIMAL          (10,3)        

)        

3.創(chuàng)建元數(shù)據(jù)

CREATE                     TABLE                     mysql_test (        

           id           INT                     NOT                     NULL          ,        

           name                     STRING,        

           description STRING,        

           weight           DECIMAL          (10,3)        

)           WITH                     (        

           'connector'                     =           'mysql-cdc'          ,        

           'hostname'                     =           'localhost'          ,        

           'port'                     =           '3306'          ,        

           'username'          =          'root'          ,        

           'password'          =          'root'          ,        

           'database-name'                     =           'test'          ,        

           'table-name'                     =           'test'        

);        

4.使用查詢sql

SELECT                     id,           UPPER          (          name          ), description, weight           FROM                     mysql_test;        

5.增加和刪除表字段測試

增加不影響

刪除表字段后，會出錯

[ERROR] Could not execute SQL statement. Reason:
org.apache.kafka.connect.errors.DataException: name is not a valid field name

注：mysql的版本如果是8.0，flink端鏈接會出錯

com.github.shyiko.mysql.binlog.network.AuthenticationException: Client does not support authentication protocol requested by server; consider upgrading MySQL client 

出現(xiàn)上述問題的原因是：mysql8 之前的版本中加密規(guī)則是mysql_native_password,而在mysql8之后,加密規(guī)則是caching_sha2_password 把mysql用戶登錄密碼加密規(guī)則還原成mysql_native_password

解決方案：在mysql中執(zhí)行以下命令

alter user 'root'@'%' identified with mysql_native_password by 'root';  修改認(rèn)證規(guī)則

flush privileges;  刷新權(quán)限

感謝各位的閱讀，以上就是“flink mysql數(shù)據(jù)接入的方法”的內(nèi)容了，經(jīng)過本文的學(xué)習(xí)后，相信大家對flink mysql數(shù)據(jù)接入的方法這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是創(chuàng)新互聯(lián)，小編將為大家推送更多相關(guān)知識點的文章，歡迎關(guān)注！


分享文章：flinkmysql數(shù)據(jù)接入的方法
本文地址：http://weahome.cn/article/jojses.html

其他資訊

在線咨詢

微信咨詢

電話咨詢

028-86922220（工作日）

18980820575（7×24）

提交需求

返回頂部