Kinesis Data Analytics for Java Applications 的早期版本信息 - Amazon Kinesis Data Analytics
使用 Apache Flink 1.6.2 构建应用程序升级应用程序Apache Flink 1.6.2 中的可用连接器
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅中国的 AWS 服务入门。

Kinesis Data Analytics for Java Applications 的早期版本信息

本主题包含有关将 Kinesis Data Analytics for Java Applications 与旧 Apache Flink 版本一起使用的信息。Kinesis Data Analytics 支持的 Apache Flink 版本是 1.8.2（建议）和 1.6.2。

本主题包含下列部分：

使用 Apache Flink 1.6.2 构建应用程序

本节包含有关用于构建与 Apache Flink 1.6.2 一起使用的 Kinesis Data Analytics 应用程序的组件的信息。

可以在 Kinesis Data Analytics 应用程序中使用以下组件版本：

组件 版本
Java 1.8（建议）
AWS Java 软件开发工具包 1.11.379
Apache Flink 1.6.2
适用于 Flink 的 Kinesis Data Analytics 运行时 (aws-kinesisanalytics-runtime) 1.0.1
Kinesis Data Analytics Flink 连接器 (aws-kinesisanalytics-flink) 1.0.1
Apache Maven 3.1
注意

在使用 Kinesis Data Analytics 运行时版本 1.0.1 时，您可以在 pom.xml 文件中指定 Apache Flink 版本，而不是在编译应用程序代码时使用 -Dflink.version 参数。

有关使用 Apache Flink 版本 1.6.2 的 Kinesis Data Analytics 应用程序的 pom.xml 文件的示例，请参阅适用于 Flink 1.6.2 的 Kinesis Data Analytics 入门应用程序。

有关如何为 Kinesis Data Analytics 应用程序构建和使用应用程序代码的信息，请参阅创建应用程序。

将应用程序从 Apache Flink 1.6.2 升级到 1.8.2

要将 Kinesis Data Analytics 应用程序从 Apache Flink 1.6.2 升级到 1.8.2，请执行以下操作：

  • 将应用程序的 pom.xml 文件中的 Kinesis Data Analytics 运行时和 Kinesis Data Analytics Flink 连接器 (aws-kinesisanalytics-flink) 版本更改为 1.1.0。

  • 从应用程序的 pom.xml 文件中删除 flink.version 属性。在下一步中编译应用程序代码时，您将提供该参数。

  • 使用以下命令重新编译应用程序代码：

    mvn package -Dflink.version=1.8.2

  • 删除现有的应用程序。再次创建应用程序，并为应用程序的 Runtime (运行时) 选择 Apache Flink 1.8 (Recommended version) (Apache Flink 1.8 (建议的版本))。

Apache Flink 1.6.2 中的可用连接器

Apache Flink 框架包含用于从各种源中访问数据的连接器。有关 Apache Flink 1.6.2 框架中提供的连接器的信息，请参阅 Apache Flink 文档中的连接器。