带有不支持的 Kinesis 连接器的应用程序 - Managed Service for Apache Flink
拒绝错误 补救步骤
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

Amazon Managed Service for Apache Flink 之前称为 Amazon Kinesis Data Analytics for Apache Flink。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

带有不支持的 Kinesis 连接器的应用程序

如果应用程序使用绑定到应用程序 JAR 或存档 (ZIP) 的不支持的 Kinesis Connector 版本（1.15.2 之前版本），则 Apache Flink 1.15 版本的 Managed Service for Apache Flink 将自动拒绝应用程序的启动或更新。

拒绝错误

通过提交创建/更新应用程序调用时，您将看到以下错误：

An error occurred (InvalidArgumentException) when calling the CreateApplication operation: An unsupported Kinesis connector version has been detected in the application. Please update flink-connector-kinesis to any version equal to or newer than 1.15.2.
For more information refer to connector fix: https://issues.apache.org/jira/browse/FLINK-23528

补救步骤

  • 更新应用程序对的依赖关系flink-connector-kinesis。如果您使用 Maven 作为项目的构建工具，请按照以下步骤操作更新 Maven 依赖关系 。如果您使用的是 Gradle，请按照更新 Gradle 依赖关系 。

  • 重新打包应用程序。

  • 上传到 Amazon S3 存储桶

  • 重新提交创建/更新申请请求，修改后的应用程序刚刚上传到 Amazon S3 存储桶。

  • 如果您继续看到相同的错误消息，请重新检查您的应用程序依赖关系。如果问题仍然存在，请创建支持请求。

更新 Maven 依赖关系

  1. 打开项目的pom.xml。

  2. 查找项目的依赖关系。它们看起来像：

    <project>

    ...

    <dependencies>

        ...

        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-connector-kinesis</artifactId>
        </dependency>

        ...

    </dependencies>

    ...

</project>

  3. 更新flink-connector-kinesis到等于或高于 1.15.2 的版本。例如：

    <project>

    ...

    <dependencies>

        ...

        <dependency>
            <groupId>org.apache.flink</groupId>
            <artifactId>flink-connector-kinesis</artifactId>
            <version>1.15.2</version>
        </dependency>

        ...

    </dependencies>

    ...

</project>

更新 Gradle 依赖关系

  1. 打开项目build.gradle（或build.gradle.kts针对 Kotlin 应用程序）。

  2. 查找项目的依赖关系。它们看起来像：

    ...

dependencies {

    ...

    implementation("org.apache.flink:flink-connector-kinesis")

    ...

}

...

  3. 更新flink-connector-kinesis到等于或高于 1.15.2 的版本。例如：

    ...

dependencies {

    ...

    implementation("org.apache.flink:flink-connector-kinesis:1.15.2")

    ...

}

...