启动 yarn-session
cd /program/flink-1.12.5
bin/yarn-session.sh
或者 后台执行
bin/yarn-session.sh -d
执行结果如下：
看到上面红框处，说明启动成功
flink web ui
访问 http://hadoop1:43347 可查看 web ui
yarn web ui
访问：http://hadoop2:8088/ 查看 yarn web ui
提交任务
如下：
bin/flink run /program/flink-1.12.5/examples/batch/WordCount.jar --input hdfs://hadoop1:8020/test2/data.txt --output hdfs://hadoop1:8020/flink_result8
解释：
--input：要读取的文件路径--output：要保存结果的文件
flink web ui
访问 http://hadoop1:43347 可查看 web ui
查看结果
访问 HDFS：http://hadoop1:9870/ ，如下图：
文件内容如下：
lili 1
lucy 2
例子：指定启动类
如下：
bin/flink run -c map.TestMap2 /program/flink-1.0-SNAPSHOT.jar
解释：
-c：主启动启动类