flink的sql測(cè)試，怎么測(cè)試

• 怎么打開flink的sql客戶端測(cè)試
• 粘貼上語(yǔ)句
• flink的web頁(yè)面展示成功

官網(wǎng)的鏈接可以直接看（中文版可以放心食用）

怎么打開flink的sql客戶端測(cè)試

首先到flink的bin目錄下

/opt/flink-1.15.0/bin

然后執(zhí)行./sql-client.sh

./sql-client.sh embedded

然后就會(huì)出現(xiàn)如下的圖，說明啟動(dòng)成功了

粘貼上語(yǔ)句

create table source

create table t_shh_source(name String) WITH ( 'connector' = 'jdbc','url' = 'jdbc:mysql://192.168.1.91:3306/test','table-name' = 't_shh_source', 'username' = 'root', 'password' = 'dk123456','driver' = 'com.mysql.cj.jdbc.Driver');

create table target

create table t_shh_target(name String) WITH ('connector' = 'jdbc','url' = 'jdbc:mysql://192.168.1.91:3306/test','table-name' = 't_shh_target', 'username' = 'root','password' = 'dk123456','driver' = 'com.mysql.cj.jdbc.Driver');

DDL

insert into t_shh_target select name from t_shh_source;

flink的web頁(yè)面展示成功

總結(jié)

以上是生活随笔為你收集整理的flink的测试sql怎么测试呢，不能每次都使用jar测试吧，那么sqk-client就来了的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。