サポートされていない Kinesis コネクタを使用するアプリケーション - Managed Service for Apache Flink
拒否エラー 修正手順

Amazon Managed Service for Apache Flink は、以前は Amazon Kinesis Data Analytics for Apache Flink と呼ばれていました。

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

サポートされていない Kinesis コネクタを使用するアプリケーション

Managed Service for Apache Flink for Apache Flink バージョン 1.15 以降では、アプリケーションまたはアーカイブ () にバンドルされたサポートされていない Kinesis Connector バージョン (バージョン 1.15.2 以前) を使用している場合、アプリケーションの開始または更新が自動的に拒否されます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")

    ...

}

...