flink1.12.x 执行官方例子-wordcount

仅执行 WordCount

/program/flink-1.12.5/bin/flink run /program/flink-1.12.5/examples/batch/WordCount.jar

读取默认文件,并将结果打印到控制台上

执行 WordCount 读写本地文件

/program/flink-1.12.5/bin/flink run /program/flink-1.12.5/exampl              es/batch/WordCount.jar --input /program/data.txt --output /program/result.txt

解释:

  • run:后面是 .jar 路径,在 exampl 目录下有很多例子

  • --input:读取文件路径

  • --output:输出结果文件路径

执行 WordCount 读写 HDFS文件

/program/flink-1.12.5/bin/flink run /program/flink-1.12.5/examples/batch/WordCount.jar --input hdfs://hadoop1:8020/test/data.txt --output hdfs://hadoop1:8020/result3

原文出处:/show_1IX1ym5Y8dew.html