View a markdown version of this page

带有不支持的 Kinesis 连接器的应用程序 - Managed Service for Apache Flink
拒绝错误补救步骤

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

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

如果应用程序使用绑定到应用程序或存档 (ZIP) 的不支持的 Kinesis Connector 版本（1.15.2 之前的版本），则适用于 Apache Flink 1.15 或更高版本的 Apache Flink 托管服务将自动拒绝应用程序的启动或更新。 JARs

拒绝错误

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

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")

    ...

}

...