flink框架如何安装

下面以**常见环境（Linux / macOS，单机 / 集群）**为例，说明 Apache Flink 的安装方式。如果你用的是 Windows 或 Docker / Kubernetes，我也可以单独补充。

一、安装前准备

1. 环境要求

• JDK 8 或 JDK 11（Flink 1.14+ 推荐 JDK 11）
• 操作系统：Linux / macOS / Windows
• 内存：本地测试 ≥ 4G

检查 Java：

java -version

二、单机版安装（最常用，适合学习）

方式一：直接下载二进制包（推荐）

1. 下载 Flink

去官网：https://flink.apache.org/downloads.html

例如（Linux）：

wget https://downloads.apache.org/flink/flink-1.18.0/flink-1.18.0-bin-scala_2.12.tgz
tar -xzf flink-1.18.0-bin-scala_2.12.tgz
cd flink-1.18.0

2. 启动 Flink

./bin/start-cluster.sh

3. 验证

访问 Web UI：

http://localhost:8081

4. 停止 Flink

./bin/stop-cluster.sh

三、提交一个示例任务

./bin/flink run examples/streaming/WordCount.jar

查看输出：

tail log/flink-*-taskexecutor-*.out

四、集群模式（简单说明）

Standalone 集群

• 一台 JobManager
• 多台 TaskManager

编辑配置文件：

conf/flink-conf.yaml
conf/masters
conf/workers

启动：

./bin/start-cluster.sh

五、使用 Docker 安装（可选，最省事）

docker run -p 8081:8081 apache/flink:1.18.0-scala_2.12

六、常见问题

1. 端口被占用

修改：

rest.port: 8082

2. JDK 版本不对

Flink 1.18 推荐：

• JDK 11

3. 内存不足

taskmanager.memory.process.size: 2048m

七、下一步你可以学什么

• DataStream API
• Flink SQL
• Checkpoint / State
• Kafka + Flink

如果你告诉我：

• 操作系统（Linux / Windows / Mac）
• 是否用 Docker / K8s
• 是否做实时计算 / 批处理

我可以给你更精确的安装方案。