目錄

• 1. 啟動SQL Client
• 2. SQL Client結果查看模式
• 3. 同步 / 異步執行DML語句

1. 啟動SQL Client

先啟動Flink集群

[root@flink1 ~]# [root@flink1 ~]# flink-1.14.3/bin/sql-client.sh ......省略部分...... Flink SQL>

目前sql-client.sh只能連接本地的集群，不能連接遠程的集群

2. SQL Client結果查看模式

1. table模式

將結果物化到內存，再顯示。可以通過上下翻頁查看更多數據

可以按q退出結果查看

Flink SQL> set 'execution.runtime-mode' = 'streaming'; [INFO] Session property has been set.Flink SQL> set 'sql-client.execution.result-mode' = 'table'; [INFO] Session property has been set.Flink SQL> select my_name, count(*) as cnt > from (values('Bob'), ('Alice'), ('Greg'), ('Bob')) as my_table(my_name) > group by my_name;SQL Query Result (Table) Table program finished. Page: Last of 1 Updated: 07:32:16.080 my_name cntAlice 1Greg 1Bob 2Q Quit + Inc Refresh G Goto Page N Next Page O Open Row R Refresh - Dec Refresh L Last Page P Prev Page

2. changelog模式

結果是變更日志的形式，只顯示最近1000條日志。不支持batch模式

Flink SQL> set 'execution.runtime-mode' = 'streaming'; [INFO] Session property has been set.Flink SQL> set 'sql-client.execution.result-mode' = 'changelog'; [INFO] Session property has been set.Flink SQL> select my_name, count(*) as cnt > from (values('Bob'), ('Alice'), ('Greg'), ('Bob')) as my_table(my_name) > group by my_name;SQL Query Result (Changelog) Table program finished. Updated: 07:34:14.074 op my_name cnt+I Bob 1+I Alice 1+I Greg 1-U Bob 1+U Bob 2Q Quit + Inc Refresh O Open Row R Refresh - Dec Refresh

tableau模式
以表格的形式，顯示變更日志的數據

Flink SQL> set 'execution.runtime-mode' = 'streaming'; [INFO] Session property has been set.Flink SQL> set 'sql-client.execution.result-mode' = 'tableau'; [INFO] Session property has been set.Flink SQL> select my_name, count(*) as cnt > from (values('Bob'), ('Alice'), ('Greg'), ('Bob')) as my_table(my_name) > group by my_name; +----+--------------------------------+----------------------+ | op | my_name | cnt | +----+--------------------------------+----------------------+ | +I | Bob | 1 | | +I | Alice | 1 | | +I | Greg | 1 | | -U | Bob | 1 | | +U | Bob | 2 | +----+--------------------------------+----------------------+ Received a total of 5 rowsFlink SQL>

如果未執行完，可以按Ctrl + C結束此條SQL查詢

3. 同步 / 異步執行DML語句

默認是異步執行DML語句，提交完DML語句，就退出。如果要取消提交完但正在執行的DML任務，可以通過Web、命令行、Restful API

Flink SQL> create temporary table blackhole_table( > name string > ) with ('connector' = 'blackhole'); [INFO] Execute statement succeed.Flink SQL> insert into blackhole_table select name from (values('zhang_san'), ('li_si'), ('wang_wu')) as source_table(name); [INFO] Submitting SQL update statement to the cluster... [INFO] SQL update statement has been successfully submitted to the cluster: Job ID: a927e6b6320391d86056f6204f669a6a

對于Batch模式，通常需要同步執行DML。可以按Ctrl + C取消正在同步執行的DML任務

Flink SQL> set 'table.dml-sync'='true'; [INFO] Session property has been set.Flink SQL> insert into blackhole_table select name from (values('zhang_san'), ('li_si'), ('wang_wu')) as source_table(name); [INFO] Submitting SQL update statement to the cluster... [INFO] Execute statement in sync mode. Please wait for the execution finish... [INFO] Complete execution of the SQL update statement.Flink SQL>

總結

以上是生活随笔為你收集整理的Flink SQL Client的使用的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。