Flink 搭建 - 本地模式

• • • 模式说明
    • 安装准备
    • 安装测试

Apache Flink 1.10 Documentation

模式说明

本地模式适用于本地开发和测试环境，占用的资源较少，部署简单

安装准备

① 环境准备

Linux 服务器

② 下载安装包

Apache Flink: Downloads

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()

⑥ 访问UI