應用程式使用不支援的 Kinesis 連接器 - Managed Service for Apache Flink
拒絕錯誤要修復的步驟

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

應用程式使用不支援的 Kinesis 連接器

Managed Service for Apache Flink 1.15 版或更新版本會在應用程式使用不支援的 Kinesis Connector 版本 (1.15.2 版之前） 封裝至應用程式 JAR 或封存檔 (ZIP) 時，自動拒絕應用程式啟動或更新。 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 (或針對 Kotlin 應用程式的 build.gradle.kts)。

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

    ...

}

...