Flink 搭建 - 本地模式
Apache Flink 1.10 Documentation
模式说明
本地模式适用于本地开发和测试环境，占用的资源较少，部署简单
安装准备
① 环境准备
Linux 服务器
② 下载安装包
Apache Flink: Downloads: flink-1.10.0-bin-scala_2.11.tgz
注意：本博客基于 Flink 1.10 版本安装
# 版本说明
# 1.10.0 是 flink 的版本，2.11 是 scala 的版本
flink-1.10.0-bin-scala_2.11.tgz
安装测试
① 上传解压
cd /opt/server
chmod u+x flink-1.10.0-bin-scala_2.11.tgz
tar -zxvf flink-1.10.0-bin-scala_2.11.tgz
② 软连接
cd /opt/server
chown -R root:root flink-1.10.0
ln -s /opt/server/flink-1.10.0 /opt/server/flink
③ 创建测试文件
vim /opt/server/words.txt
# 增加以下内容
aaa bbb ccc ddd
lucy jack lucy
Beijing Wuhan
jack
④ 启动本地 flink
cd /opt/server/flink
bin/start-scala-shell.sh local
benv.readTextFile("/opt/server/words.txt").flatMap(_.split(" ")).map((_,1)).groupBy(0).sum(1).print()
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 [email protected] 举报，一经查实，本站将立刻删除。
