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