Apache Flink快速入门-本地快速安装

按照以下几个步骤下载最新的稳定版本并开始使用。

第 1 步：下载 

为了能够运行 Flink，唯一的要求是安装了Java 8 或 11。您可以通过发出以下命令来检查 Java 的正确安装：

java -version

下载1.13.0 版本并解压缩它。

$ tar -xzf flink-1.13.0-bin-scala_2.11.tgz
$ cd flink-1.13.0-bin-scala_2.11

第 2 步：启动集群 

Flink 附带一个 bash 脚本来启动本地集群。

$ ./bin/start-cluster.sh
Starting cluster.
Starting standalonesession daemon on host.
Starting taskexecutor daemon on host.

第 3 步：提交作业 

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来监控集群和运行作业的状态。

第 4 步：停止集群 

完成后，您可以快速停止集群和所有正在运行的组件。

$ ./bin/stop-cluster.sh