Apache Flink - 命令

• $flink命令位置 命令 選項 jar包位置 \ --input 輸入文件位置 --out 輸出文件位置
• ./bin/flink run ./examples/batch/WordCount.jar         在flink目錄下運行WordCount.jar
• ./bin/flink run -p 16 ./examples/batch/WordCount.jar \ --input file:///home/user/hamlet.txt --output        file:///home/user/wordcount_out       在flink下運行WordCount.jar，並且輸入文件為/home/user/hamlet.txt，輸出文件為/home/user/wordcount_out

• 選項   -p 16    帶有並行性的示例程序16
           -q        禁用flink log輸出
           -d        分離模式運行
           -m JobManagerHost:8081 \   在特定的JobManager上運行示例程序
           -c org.apache.flink.examples.java.wordcount.WordCount \     以特定類作為入口點運行示例程序
           -m yarn-cluster -yn 2 \           使用具有2個TaskManagers 的 per-job YARN cluster運行示例程序
  

  　　

• /bin/flink info ./examples/batch/WordCount.jar \ --input file:///home/user/hamlet.txt --output file:///home/user/wordcount_out      以Word為單位顯示WordCount示例程序的優化執行計划    

• ./bin/flink list   列出計划和正在運行的job

• ./bin/flink list -s   列出預定job

  ./bin/flink list -r   列出正在運行的job

• ./bin/flink list -m yarn-cluster -yid <yarnApplicationID> -r   列出在YARN 中運行的job

• ./bin/flink cancel <jobID>  通過jobID取消job

• ./bin/flink stop <jobID>    通過jobID停止job