1.创建工程

打开 IntelliJ IDEA，创建一个 Maven 工程

2.添加项目依赖

在项目的 pom 文件中，增加标签设置属性，然后增加标签引 入需要的依赖。我们需要添加的依赖最重要的就是 Flink 的相关组件，包括 flink-java、 flink-streaming-java，以及 flink-clients（客户端，也可以省略）。另外，为了方便查看运行日志， 我们引入 slf4j 和 log4j 进行日志管理。 

  1. <properties>
  2.    <flink.version>1.13.0</flink.version>
  3.    <java.version>1.8</java.version>
  4.    <scala.binary.version>2.12</scala.binary.version>
  5.    <slf4j.version>1.7.30</slf4j.version>
  6. </properties>
  7. <dependencies>
  8. <!-- 引入 Flink 相关依赖-->
  9.    <dependency>
  10.      <groupId>org.apache.flink</groupId>
  11.      <artifactId>flink-java</artifactId>
  12.      <version>${flink.version}</version>
  13.    </dependency>
  14.    <dependency>
  15.      <groupId>org.apache.flink</groupId>
  16.      <artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
  17.      <version>${flink.version}</version>
  18.    </dependency>
  19.    <dependency>
  20.      <groupId>org.apache.flink</groupId>
  21.      <artifactId>flink-clients_${scala.binary.version}</artifactId>
  22.      <version>${flink.version}</version>
  23.   </dependency>
  24.   <!-- 引入日志管理相关依赖-->
  25.    <dependency>
  26.      <groupId>org.slf4j</groupId>
  27.      <artifactId>slf4j-api</artifactId>
  28.      <version>${slf4j.version}</version>
  29.    </dependency>
  30.    <dependency>
  31.      <groupId>org.slf4j</groupId>
  32.      <artifactId>slf4j-log4j12</artifactId>
  33.      <version>${slf4j.version}</version>
  34.    </dependency>
  35.    <dependency>
  36.      <groupId>org.apache.logging.log4j</groupId>
  37.      <artifactId>log4j-to-slf4j</artifactId>
  38.      <version>2.14.0</version>
  39.   </dependency>
  40. </dependencies>

3.配置日志管理

在目录 src/main/resources 下添加文件:log4j.properties，内容配置如下： 

  1. log4j.rootLogger=error, stdout
  2. log4j.appender.stdout=org.apache.log4j.ConsoleAppender
  3. log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
  4. log4j.appender.stdout.layout.ConversionPattern=%-4r [%t] %-5p %c %x - %m%n