本系列博客由Flink1.11版本官方文档纯手动翻译而来,并对部分内容做了优化调整。
Flink1.11版本原文档首页地址:
https://ci.apache.org/projects/flink/flink-docs-release-1.11/
本文对应原文档地址:
https://ci.apache.org/projects/flink/flink-docs-release-1.11/try-flink/local_installation.html
Flink 本地安装
接下来的步骤,您将会下载Flink的最新稳定版本并且开始安装。
第一步:下载Flink
为了运行Flink,您的环境中需要具备Java 8 或者 Java 11的开发环境。
你可以输入以下命令来检查是否具备了正确的Java开发环境。
java -version
下载Flink 1.11.2版本安装包,并解压
$ tar -xzf flink-1.11.2-bin-scala_2.11.tgz
$ cd flink-1.11.2-bin-scala_2.11
第二步:启动一个Flink集群
Flink附带了一个脚本来启动本地集群,在Flink的bin目录下运行./start-cluster.sh
即可启动Flink集群:
$ ./bin/start-cluster.sh
Starting cluster.
Starting standalonesession daemon on host.
Starting taskexecutor daemon on host.
第三步:提交一个任务
Flink附带了一系列示例的任务,您可以快速部署这些示例任务到运行的集群中,例如:
$ ./bin/flink run examples/streaming/WordCount.jar
$ tail log/flink-*-taskexecutor-*.out
(to,1)
(be,1)
(or,1)
(not,1)
(to,2)
(be,2)
此外,您可以查看Flink的WEB UI来监控Flink集群以及正在运行的Flink任务。
第四步:停止集群
任务运行结束后,您可以通过以下脚本来快速停止正在运行中的Flink集群和所有运行中的Flink组件。
$ ./bin/stop-cluster.sh