第一步:安装 Java 运行环境
首先我们需要安装 Java 运行环境,Flink 是基于 Java 编写的,所以在安装和运行 Flink 之前,需要先安装 JavaSE Development Kit(JDK)。

1. 下载 JDK:从 Oracle 官网下载适合你操作系统的 JDK 版本,下载地址为:https://www.oracle.com/java/technologies/javase-jdk11-downloads.html

2. 安装 JDK:双击下载好的 JDK 安装包,按照提示进行安装。安装完成后,打开命令行工具,输入 java-version 命令,如果成功显示 Java 版本信息,则说明 JDK 安装成功。

第二步:下载 Flink
1. 下载 Flink:打开 Flink 官网(https://flink.apache.org/),点击页面中间的“Download”按钮,选择合适的 Flink 版本和下载方式。通常情况下,我们选择下载二进制文件(.tar.gz 格式)。

2. 解压 Flink:将下载好的 Flink 二进制文件解压到你想要安装的目录下,解压完成后,你会得到一个 Flink 文件夹。

第三步:启动 Flink 集群
1. 进入 Flink 目录:在命令行工具中,切换到 Flink 安装目录,例如 cdpath/flk

2. 启动 Flink 集群:运行以下命令启动 Flink 集群。

./bin/start-cluster.sh
Shell

3. 验证:启动完成后,你可以通过访问 http://localhost:8081 来访问 Flink 的 Web 界面。如果成功访问到 Flink 的 Web 界面,则说明 Flink 集群启动成功。

4. 停止 Flink 集群:如果需要停止 Flink 集群,可以运行以下命令。

./bin/stop-cluster.sh
Shell

至此,你已经成功安装并启动了 Flink 集群。你可以使用 Flink 提供的 API 或者其他工具来开发和提交 Flink 作业了。记得在使用 Flink 之前,确保你已经熟悉了 Flink 的相关文档和教程,以便更好地使用和优化 Flink。