サポートされていない 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")
   
       ...
   
   }
   
   ...