在 pom.xml 文件中添加以下依赖:

<dependencies>
  <!-- other dependencies -->
  
  <!-- Flink dependencies -->
  <dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-java</artifactId>
    <version>1.13.1</version>
  </dependency>
  <dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-streaming-java_2.12</artifactId>
    <version>1.13.1</version>
  </dependency>
  <dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-clients_2.12</artifactId>
    <version>1.13.1</version>
  </dependency>
  
  <!-- other dependencies -->
</dependencies>

这些依赖包括了 Flink 的核心库和客户端库,可以满足大部分 Flink 应用的需要。根据实际情况,你还可以添加其他 Flink 模块的依赖,比如:

  • flink-connector-kafka:Kafka 连接器。
  • flink-connector-filesystem:文件系统连接器,支持本地文件系统、HDFS 等。
  • flink-connector-jdbc:JDBC 连接器,可以连接关系型数据库。
  • flink-ml:Flink 的机器学习库。
  • 等等。

不同的 Flink 版本可能需要不同的依赖版本,请根据实际情况选择合适的版本

java 开发pomxml 增加flink-1131maven 依赖

原文地址: https://www.cveoy.top/t/topic/fhyu 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录