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