仅执行 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