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

Amazon Managed Service for Apache Flink 之前稱為 Amazon Kinesis Data Analytics for Apache Flink。

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

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

適用於 Apache Flink 1.15 版或更新版本的 Apache Flink 受管理服務，如果應用程式使用捆綁到應用程式或歸檔中的不支援 Kinesis 連接器版本 (1.15.2 之前版本)，則會自動拒絕應用程式啟動或更新。JARs ZIP

拒絕錯誤

透過以下方式提交建立/更新應用程式的呼叫時，將看到以下錯誤：

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

    ...

}

...