This documentation is for an unreleased version of Apache Flink. We recommend you use the latest stable version.

第一步 #

欢迎使用 Apache Flink！本指南将帮助您启动并运行 Flink 集群，以便开始探索 Flink 的功能。

前提条件 #

选择以下安装方式之一：

• Docker：无需安装 Java，包含 SQL 客户端
• 本地安装：需要 Java 11、17 或 21
• PyFlink：需要 Java 和 Python 3.9+

选项 A：Docker 安装 #

最快的 Flink 入门方式。无需安装 Java。

步骤 1：获取 docker-compose.yml 文件 #

下载 docker-compose.yml 或创建一个名为 docker-compose.yml 的文件，内容如下：

services:
  jobmanager:
    image: flink:latest
    ports:
      - "8081:8081"
    command: jobmanager
    environment:
      - |
        FLINK_PROPERTIES=
        jobmanager.rpc.address: jobmanager        

  taskmanager:
    image: flink:latest
    depends_on:
      - jobmanager
    command: taskmanager
    scale: 1
    environment:
      - |
        FLINK_PROPERTIES=
        jobmanager.rpc.address: jobmanager
        taskmanager.numberOfTaskSlots: 2        

  sql-client:
    image: flink:latest
    depends_on:
      - jobmanager
    command: bin/sql-client.sh
    environment:
      - |
        FLINK_PROPERTIES=
        jobmanager.rpc.address: jobmanager
        rest.address: jobmanager        

步骤 2：启动集群 #

$ docker compose up -d

步骤 3：验证集群正在运行 #

打开 Flink Web UI http://localhost:8081 以验证集群正在运行。

使用 SQL 客户端 #

启动交互式 SQL 会话：

$ docker compose run sql-client

要退出 SQL 客户端，输入 exit; 并按回车键。

停止集群 #

$ docker compose down

有关更多 Docker 选项（扩缩容、Application 模式），请参阅 Docker 部署指南。

选项 B：本地安装 #

如果您更喜欢在本机上直接运行 Flink 而不使用 Docker。

步骤 1：下载 Flink #

Flink 可在所有类 UNIX 环境中运行，包括 Linux、Mac OS X 和 Cygwin（Windows）。

首先，验证您的 Java 版本：

$ java -version

您需要安装 Java 11、17 或 21。然后，下载最新的二进制发行版 并解压：

$ tar -xzf flink-*.tgz
$ cd flink-*

步骤 2：启动集群 #

启动本地 Flink 集群：

$ ./bin/start-cluster.sh

步骤 3：验证集群正在运行 #

打开 Flink Web UI http://localhost:8081 以验证集群正在运行。您应该看到 Flink 仪表板显示一个 TaskManager 和可用的任务槽。

使用 SQL 客户端 #

启动交互式 SQL 会话：

$ ./bin/sql-client.sh

要退出 SQL 客户端，输入 exit; 并按回车键。

停止集群 #

完成后，使用以下命令停止集群：

$ ./bin/stop-cluster.sh

选项 C：PyFlink 安装 #

用于使用 Table API 或 DataStream API 进行 Python 开发。无需 Flink 集群——PyFlink 在开发过程中以本地模式运行。

步骤 1：验证前提条件 #

PyFlink 需要 Java 和 Python：

$ java -version
# Java 11、17 或 21

$ python --version
# Python 3.9、3.10、3.11 或 3.12

步骤 2：安装 PyFlink #

$ python -m pip install apache-flink

提示： 我们建议在 虚拟环境 中安装 PyFlink，以保持项目依赖隔离。

步骤 3：验证安装 #

$ python -c "import pyflink; print(pyflink.__version__)"

您现在可以使用 Python 选项卡来学习 Table API 教程 或 DataStream API 教程。

下一步 #

选择一个教程开始学习：

要了解有关 Flink 核心概念的更多信息，请访问 概念 部分。