上一篇文章《Flink应用开发系列(一)创建一个java项目模板》我们创建了一个基础的模板。在pom.xml中我们可以看到默认引入了好几个依赖,示例如下:
<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</artifactId>
<version>${flink.version}</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.7.7</version>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.17</version>
<scope>runtime</scope>
</dependency>这里的flink-java和flink-streaming-java_xx这两个依赖就是我们在java项目里面编写代码的最基本的依赖,所有flink相关的java项目都需要引入这两个依赖。这里的版本根据我们实际的情况选择即可。
备注:
1、flink-java版本的依赖,可参考:https://mvnrepository.com/artifact/org.apache.flink/flink-java
2、flink-streaming-java版本的依赖,可参考:https://mvnrepository.com/artifact/org.apache.flink/flink-streaming-java
3、上诉的flink-java版本需要和flink-streaming-java版本保持一致。
4、在高版本的flink中,我们已经不需要依赖scala的版本了。









还没有评论,来说两句吧...