一、背景
一直很好奇,Flink是如何运行我们的java类任务的,今天先记录下。
二、步骤
1、项目中添加Maven 依赖项
<dependencies>
<!-- Flink Core -->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-java</artifactId>
<version>1.15.0</version>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_2.12</artifactId>
<version>1.15.0</version>
</dependency>
<!-- Flink Kafka Connector -->
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-kafka_2.12</artifactId>
<version>1.15.0</version>
</dependency>
<!-- Flink MySQL Connector -->
<dependency>
<groupId>org.apache