flink的sql測試，怎么測試

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

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

怎么打開flink的sql客戶端測試

首先到flink的bin目錄下

/opt/flink-1.15.0/bin

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

./sql-client.sh embedded

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

粘貼上語句

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頁面展示成功

總結(jié)

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

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