1 standalone模式
1.1 安装
解压缩 flink-1.7.0-bin-hadoop27-scala_2.11.tgz
修改 flink/conf/flink-conf.yaml 文件

修改 /conf/slave文件

.分发给 另外两台机子

启动


1.2 提交任务
1) 准备数据文件

2) 把含数据文件的文件夹,分发到taskmanage 机器中

由于读取数据是从本地磁盘读取,实际任务会被分发到taskmanage的机器中,所以要把目标文件分发。
3) 执行程序
./flink run -c com.atguigu.flink.app.BatchWcApp /ext/flink0503-1.0-SNAPSHOT.jar –input /applog/flink/input.txt –output /applog/flink/output.csv |

4) 到目标文件夹中查看计算结果

注意:计算结果根据会保存到taskmanage的机器下,不会再jobmanage下。
5) 在webui控制台查看计算过程

想要了解跟多关于大数据培训课程内容欢迎关注尚硅谷大数据培训,尚硅谷除了这些技术文章外还有免费的高质量大数据培训课程视频供广大学员下载学习
上一篇: Java培训课程Redis之常用API
下一篇: 前端培训之js去除字符串空格