gpt4 book ai didi

amazon-web-services - 如何构建和使用flink-connector-kinesis?

转载 作者:行者123 更新时间:2023-12-03 16:13:16 24 4
gpt4 key购买 nike

我正在尝试将Apache Flink与AWS kinesis结合使用。 document说,我必须自己构建连接器。

因此,我建立了连接器并为项目添加了jar文件,并且还将依赖项放在了pom.xml文件中。

<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-kinesis_2.11</artifactId>
<version>1.6.1</version>
</dependency>

但是,当我尝试使用 mvn clean package进行构建时,出现了这样的错误消息
[INFO] -----------------------< kkaldk:flink-kinesis >-----------------------
[INFO] Building Flink Quickstart Job 0.1
[INFO] --------------------------------[ jar ]---------------------------------
[WARNING] The POM for org.apache.flink:flink-connector-kinesis_2.11:jar:1.6-SNAPSHOT is missing, no dependency information available
[INFO] ------------------------------------------------------------------------
[INFO] BUILD FAILURE
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 0.458 s
[INFO] Finished at: 2018-12-19T17:45:43+09:00
[INFO] ------------------------------------------------------------------------
[ERROR] Failed to execute goal on project flink-kinesis: Could not resolve dependencies for project kkaldk:flink-kinesis:jar:0.1: Failure to find org.apache.flink:flink-connector-kinesis_2.11:jar:1.6-SNAPSHOT in https://repository.apache.org/content/repositories/snapshots/ was cached in the local repository, resolution will not be reattempted until the update interval of apache.snapshots has elapsed or updates are forced ->
[Help 1]
[ERROR]

你能帮我解决这个问题吗?

- - - - -添加 - - - - -

这就是我所做的(错误的过程)
  • 按照此document
  • 启动了项目
    flink master source(来自1.8快照)的
  • 构建连接器
  • 在1.6.1版本中添加依赖项。
  • 最佳答案

    这就是我为解决方案所做的事情。

  • 我从here下载了1.6.1版本。
  • 解压缩文件(存档将解压缩为.../flink-release-1.6.1/
  • mvn clean install -Pinclude-kinesis -DskipTests建成

  • 然后我的本地Maven存储库中有flink-connector-kinesis_2.11版本1.6.1

    (对我来说,路径是这样的): ~/.m2/repository/org/apache/flink/flink-connector-kinesis_2.11
    之后,通过在此项目中添加依赖关系,我可以在任何项目中使用此连接器。 (我不必再添加jar文件。)
    <dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-kinesis_2.11</artifactId>
    <version>1.6.1</version>
    </dependency>

    关于amazon-web-services - 如何构建和使用flink-connector-kinesis?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53847710/

    24 4 0
    Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
    广告合作:1813099741@qq.com 6ren.com