一、flink入口类

在执行flink代码时，需要执行的方法:

  1. ./bin/flink run 
  2. ./examples/batch/WordCount.jar 
  3. -input hdfs://SparkMaster:9000/input/README.txt 
  4. -output hdfs://SparkMaster:9000/wordcount-result.txt

我们从flink bin目录下，查看flink提交函数的入口类：org.apache.flink.client.cli.CliFrontend
image.png
接下来，进一步解析CliFrontend类，整个flink程序的入口类