跳转到内容

Flink 安装

1. Flink 核心架构理念

Apache Flink 是一个分布式的流处理引擎，能够对有界（Bounded）和无界（Unbounded）的数据流进行高效的实时计算。

批流一体：Flink 在架构层面上将“批处理”视为流处理的一种特例（即数据流有一个明确的终点边界），从而使用统一的 API 来处理实时流数据和历史存量数据。

2. 基础环境搭建 (单机 Standalone 模式)

单机模式适合进行本地代码调试与基础 API 验证。

2.1. 下载与环境变量注入

# 获取特定版本的二进制包
wget https://dlcdn.apache.org/flink/flink-1.20.0/flink-1.20.0-bin-scala_2.12.tgz
tar -zxvf flink-1.20.0-bin-scala_2.12.tgz -C /opt/software

# 配置系统环境变量
export FLINK_HOME=/opt/software/flink-1.20.0
export FLINK_CONF_DIR=$FLINK_HOME/conf
export PATH=$FLINK_HOME/bin:$PATH

2.2. 本地集群启停与验证

# 启动单机沙箱集群
start-cluster.sh

# 停止服务
stop-cluster.sh

启动成功后，可通过浏览器访问 Flink 的内置 Web 仪表盘监控计算任务： http://localhost:8081

3. 参考资料

Apache Flink 官方主页