个人学习实时数据管道框架--4 数据入湖实战

4.1 环境准备1. 安装 Java 8+ 和 Maven 3.6+2. 下载项目代码：git clone 项目地址3. 配置环境变量：JAVA_HOME, HADOOP_HOME4.2 配置文件核心配置文件 application.properties：# Flink 配置flink.job.name=VehicleSOCPipelineflink.parallelism=4flink.checkpoint.interval=60000# Kafka 配置kafka.bootstrap.servers=localhost:9092kafka.topic.input=v