flink maven配置
时间: 2023-05-25 21:00:49 浏览: 291
要在 Maven 项目中使用 Flink,需要在 pom.xml 文件中添加以下依赖:
```
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_2.11</artifactId>
<version>1.12.1</version>
</dependency>
```
此外,还需要在项目的 build 节点中添加以下插件来构建 Flink 作业:
```
<build>
<plugins>
<plugin>
<groupId>org.apache.flink</groupId>
<artifactId>flink-maven-plugin</artifactId>
<version>1.12.1</version>
<executions>
<execution>
<id>package-flink-job</id>
<goals>
<goal>build</goal>
</goals>
</execution>
</executions>
<configuration>
<jobClassName>com.example.MyFlinkJob</jobClassName>
</configuration>
</plugin>
</plugins>
</build>
```
其中,jobClassName 指定了 Flink 作业的入口点,需要根据实际情况进行修改。完成以上配置后,可以使用 Maven 打包项目并提交到 Flink 集群运行。
相关推荐
![jar](https://img-home.csdnimg.cn/images/20210720083455.png)
![docx](https://img-home.csdnimg.cn/images/20210720083331.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)