Apache Flink快速入门

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

第 1 步：下载

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

代码语言：javascript复制java -version下载1.13.0 版本并解压缩它。

代码语言：javascript复制$ tar -xzf flink-1.13.0-bin-scala_2.11.tgz

$ cd flink-1.13.0-bin-scala_2.11第 2 步：启动集群

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

代码语言：javascript复制$ ./bin/start-cluster.sh

Starting cluster.

Starting standalonesession daemon on host.

Starting taskexecutor daemon on host.第 3 步：提交作业

Flink 的发布附带了许多示例作业。您可以将这些应用程序之一快速部署到正在运行的集群中。

代码语言：javascript复制$ ./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 步：停止集群

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

代码语言：javascript复制$ ./bin/stop-cluster.sh