3、开发环境搭建：JDK、Maven、Flink集群（Standalone模式）、IDE配置

本章将搭建一套完整的 Flink 实时流处理开发环境，涵盖 JDK、Maven、Flink Standalone 集群以及 IDE 的配置。环境版本选择遵循生产级稳定性原则，确保后续回测坏账率哨兵作业能够顺利编译、部署与运行。

3.1 JDK 安装与配置

Flink 1.14.x 依赖 JDK 1.8 或 11。推荐使用 JDK 8u202（Oracle 或 OpenJDK 均可），该版本是 Flink 社区长期验证的稳定基线。

安装步骤（Linux / macOS）

1. 下载 jdk-8u202-linux-x64.tar.gz 并解压至 /usr/local/jdk1.8.0_202。
2. 配置环境变量 JAVA_HOME 与 PATH。
3. 验证安装：java -version 应输出 1.8.0_202。

# 解压
tar -zxvf jdk-8u202-linux-x64.tar.gz -C /usr/local/

# 配置环境变量（~/.bashrc 或 /etc/profile）
export JAVA_HOME=/usr/local/jdk1.8.0_202
export PATH=$JAVA_HOME/bin:$PATH

# 生效并验证
source ~/.bashrc
java -version

Windows 配置要点

• 解压后设置系统变量 JAVA_HOME 指向解压路径。
• 在 Path 中添加 %JAVA_HOME%\bin。
• 命令行执行 java -version 确认。

3.2 Maven 安装与配置

Maven 用于管理项目依赖与构建生命周期。本教程使用 Maven 3.6.3，该版本与 Flink 1.14 的 shade 插件兼容性最佳。

安装步骤

1. 下载 apache-maven-3.6.3-bin.tar.gz 并解压至 /usr/local/maven。
2. 配置 M2_HOME 与 PATH。
3. 验证：mvn -version 显示 Maven 3.6.3 及 JDK 1.8。

# 解压
tar -zxvf apache-maven-3.6.3-bin.tar.gz -C /usr/local/
mv /usr/local/apache-maven-3.6.3 /usr/local/maven

# 配置环境变量
export M2_HOME=/usr/local/maven
export PATH=$M2_HOME/bin:$PATH

# 验证
mvn -version

settings.xml 优化

在 ~/.m2/settings.xml 中配置阿里云镜像仓库，加速依赖下载：

<mirrors>
  <mirror>
    <id>aliyunmaven</id>
    <mirrorOf>central</mirrorOf>
    <name>阿里云公共仓库</name>
    <url>https://maven.aliyun.com/repository/public</url>
  </mirror>
</mirrors>

3.3 Flink Standalone 集群搭建

Standalone 模式是 Flink 最轻量的部署方式，适合开发与测试。集群包含 1 个 Master（JobManager） 和 2 个 Worker（TaskManager）。

下载与解压

wget https://archive.apache.org/dist/flink/flink-1.14.6/flink-1.14.6-bin-scala_2.12.tgz
tar -zxvf flink-1.14.6-bin-scala_2.12.tgz -C /usr/local/
mv /usr/local/flink-1.14.6 /usr/local/flink

集群配置

编辑 /usr/local/flink/conf/flink-conf.yaml：

编辑 /usr/local/flink/conf/workers，添加 Worker 节点地址：

localhost
localhost

启动与验证

# 启动集群
/usr/local/flink/bin/start-cluster.sh

# 查看进程
jps
# 应看到：StandaloneSessionClusterEntrypoint（JobManager）
#         TaskManagerRunner（TaskManager × 2）

# 访问 Web UI
# http://localhost:8081

3.4 IDE 配置（IntelliJ IDEA）

推荐使用 IntelliJ IDEA Community / Ultimate 2022+，安装以下插件以提升 Flink 开发效率：

项目导入与 JDK 关联

1. File → New → Project from Existing Sources → 选择 Maven 项目。
2. File → Project Structure → Project SDK → 选择 JDK 1.8。
3. File → Settings → Build, Execution, Deployment → Build Tools → Maven → 设置 Maven home path 为 /usr/local/maven。

Flink 运行配置模板

在 IDEA 中创建 Application 运行配置，用于本地调试 Flink 作业：

Main class: com.example.badrate.BadRateSentinelJob
Program arguments: --input kafka://localhost:9092/loan_events --output file:///tmp/badrate_result
VM options: -Dlog4j.configurationFile=file:///path/to/log4j2.xml
Working directory: $MODULE_DIR$
Use classpath of module: badrate-sentinel

3.5 环境验证清单

完成上述配置后，执行以下命令进行全链路验证：

# 1. JDK 验证
java -version
# 输出：java version "1.8.0_202"

# 2. Maven 验证
mvn -version
# 输出：Apache Maven 3.6.3

# 3. Flink 集群验证
/usr/local/flink/bin/start-cluster.sh
curl http://localhost:8081
# 返回 200 OK，页面显示集群概览

# 4. 提交测试作业
/usr/local/flink/bin/flink run /usr/local/flink/examples/streaming/SocketWindowWordCount.jar --port 9000
# 输出：Job has been submitted with JobID xxxxx

3.6 常见问题与排查