4. 开发环境搭建：JDK、Maven、Flink集群（Standalone/YARN）、IDE配置、本地调试模式

风控特征巡检对延迟极度敏感，开发环境的组件版本与集群模式直接影响调试效率与线上行为一致性。本节从 JDK 版本选型开始，逐步完成 Maven 构建配置、Flink 集群部署（Standalone 与 YARN 两种模式）、IDE 调试参数设置，最后给出本地调试的完整验证步骤。

4.1 版本选型与依赖矩阵

Flink 1.13+ 对 JDK 11 有更好的 GC 与容器支持，风控场景推荐 JDK 11。Maven 3.6+ 即可。下表列出本教程使用的核心组件版本：

4.2 JDK 与 Maven 安装验证

安装后执行以下命令验证环境变量：

# JDK 验证
java -version
# 输出示例：openjdk version "11.0.18" 2023-01-17 LTS

# Maven 验证
mvn -version
# 输出示例：Apache Maven 3.8.6

Maven 的 settings.xml 建议增加阿里云镜像，加速依赖下载：

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

4.3 Flink 集群部署：Standalone 模式

Standalone 模式适合本地开发与快速验证。下载 Flink 1.14.6 二进制包后，按以下步骤启动：

1. 解压：tar -xzf flink-1.14.6-bin-scala_2.12.tgz
2. 配置 JobManager 内存：编辑 conf/flink-conf.yaml，设置 jobmanager.memory.process.size: 2g
3. 启动集群：./bin/start-cluster.sh
4. 验证：浏览器访问 http://localhost:8081，确认 Web UI 显示 TaskManager 在线

4.4 Flink 集群部署：YARN 模式

YARN 模式是风控生产的主流选择，支持动态资源分配与队列隔离。前提是 Hadoop 集群（HDFS + YARN）已就绪。部署步骤：

4.5 IDE 配置与 Flink 插件

IntelliJ IDEA 推荐安装以下插件：

• Flink Support：提供 Flink 作业运行配置模板、SQL 语法高亮
• Scala（若使用 Scala API）
• CheckStyle-IDEA：统一风控代码规范

创建 Maven 项目后，pom.xml 核心依赖如下：

<properties>
  <flink.version>1.14.6</flink.version>
  <scala.binary.version>2.12</scala.binary.version>
</properties>

<dependencies>
  <dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-java</artifactId>
    <version>${flink.version}</version>
    <scope>provided</scope>
  </dependency>
  <dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
    <version>${flink.version}</version>
    <scope>provided</scope>
  </dependency>
  <dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-clients_${scala.binary.version}</artifactId>
    <version>${flink.version}</version>
    <scope>provided</scope>
  </dependency>
</dependencies>

4.6 本地调试模式配置

本地调试的核心思路：在 IDE 中启动一个嵌入式的 Flink MiniCluster，模拟分布式环境。配置步骤如下：

1. 创建运行配置：IDEA → Run → Edit Configurations → Add New → Application
2. 主类：填写风控作业的 main 方法全限定名
3. VM 参数：-Dlog4j.configurationFile=file:log4j2.xml（可选，用于本地日志隔离）
4. 勾选 provided 依赖：在 "Modify options" 中勾选 "Include dependencies with 'Provided' scope"
5. 设置并行度：代码中显式设置 env.setParallelism(2)，模拟多 Slot 场景

本地调试时，Flink 作业默认使用 localhost:6123 作为 JobManager 地址，无需启动外部集群。

4.7 环境搭建总览图

下图展示从开发机到 Flink 集群的完整环境链路：

4.8 本地调试快速验证

完成上述配置后，运行一个简单的风控特征计算作业验证环境：

public class LocalDebugTest {
    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        env.setParallelism(2);
        env.setRuntimeMode(RuntimeExecutionMode.STREAMING);

        DataStream<String> source = env.socketTextStream("localhost", 9999);
        source.flatMap((String line, Collector<String> out) -> {
            for (String word : line.split(",")) {
                out.collect(word);
            }
        }).returns(Types.STRING)
            .keyBy(x -> x)
            .sum(0)
            .print();

        env.execute("LocalDebugFeatureJob");
    }
}

启动 Netcat 发送数据：nc -lk 9999，输入 user_1001,user_1002,user_1001，观察 IDE 控制台输出聚合结果。若输出正确，说明 JDK、Maven、IDE 与 Flink 本地环境全部就绪。

4.9 常见环境问题与解决