如何构建和使用 flink-connector-kinesis？
How to build and use flink-connector-kinesis?
我正在尝试将 Apache Flink 与 AWS 运动结合使用。 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>
我正在尝试将 Apache Flink 与 AWS 运动结合使用。 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>