Flink客戶端操作命令
1.基于Yarn模式提交任務
使用平臺jar包測驗：
./bin/flink run -m yarn-cluster -p 2 ./examples/batch/WordCount.jar \
--input hdfs:///user/wupq/words.txt \
--output hdfs:///user/wupq/output2/2020122301
提交自己撰寫代碼：
./bin/flink run -m yarn-cluster -yn 2 -c com.tencent.tbds.demo.KafkaSourceDemo /root/wupq/tbds-demo-1.0-SNAPSHOT.jar
注意：Flink1.12版本不支持-yn引數
2.flink run
-c,–class Flink應用程式的入口
-C,–classpath 指定所有節點都可以訪問到的url,可用于多個應用程式都需要的工具類加載
-d,–detached 是否使用分離模式，就是提交任務,cli是否退出,加了-d引數,cli會退出
-n,–allowNonRestoredState 允許跳過無法還原的savepoint，比如洗掉了代碼中的部分operator
-p,–parallelism 執行并行度
-s,–fromSavepoint 從savepoint恢復任務
-sae,–shutdownOnAttachedExit 以attached模式提交，客戶端退出的時候關閉集群
3.flink yarn-cluster 模式
-d,–detached 是否使用分離模式
-m,–jobmanager 指定提交的jobmanager
-yat,–yarnapplicationType 設定yarn應用的型別
-yD <property=value> 使用給定屬性的值
-yd,–yarndetached 使用yarn分離模式
-yh,–yarnhelp yarn session的幫助
-yid,–yarnapplicationId 掛到正在運行的yarnsession上
-yj,–yarnjar Flink jar檔案的路徑
-yjm,–yarnjobManagerMemory jobmanager的記憶體(單位M)
-ynl,–yarnnodeLabel 指定 YARN 應用程式 YARN 節點標簽
-ynm,–yarnname 自定義yarn應用名稱
-yq,–yarnquery 顯示yarn的可用資源
-yqu,–yarnqueue 指定yarn佇列
-ys,–yarnslots 指定每個taskmanager的slots數
-yt,–yarnship 在指定目錄中傳輸檔案
-ytm,–yarntaskManagerMemory 每個taskmanager的記憶體
-yz,–yarnzookeeperNamespace 用來創建ha的zk子路徑的命名空間
-z,–zookeeperNamespace 用來創建ha的zk子路徑的命名空間
4.flink info
info [OPTIONS]
5.flink list(顯示正在運行或調度的程式)
-a,–all 顯示所有應用和對應的job id
-r,–running 顯示正在運行的應用和job id
-s,–scheduled 顯示調度的應用和job id
#yarn-cluster模式
-m,–jobmanager 指定連接的jobmanager
-yid,–yarnapplicationId 掛到指定的yarn id對應的yarn session上
-z,–zookeeperNamespace 用來創建ha的zk子路徑的命名空間
6. flink stop(停止一個正在運行的應用)
-d,–drain 在獲取savepoint，停止pipeline之前發送MAX_WATERMARK
-p,–savepointPath 指定savepoint的path，如果不指定會使用默認值(“state.savepoints.dir”)
7.savepoint(觸發一個正在運行的應用生成savepoint)
語法：savepoint [OPTIONS] []
-d,–dispose savepoint的路徑
-j,–jarfile Flink的jar包
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/262885.html
標籤：其他