一、背景
一直很好奇,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