Aplikasi dengan konektor Kinesis yang tidak didukung

Managed Service untuk Apache Flink untuk Apache Flink versi 1.15 atau yang lebih baru akan secara otomatis menolak aplikasi dari memulai atau memperbarui jika mereka menggunakan versi Kinesis Connector yang tidak didukung (pra-versi 1.15.2) yang dibundel ke dalam aplikasi atau arsip (). JARs ZIP

Kesalahan penolakan

Anda akan melihat kesalahan berikut saat mengirimkan panggilan aplikasi buat/perbarui melalui:

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

Langkah-langkah untuk memulihkan

• Perbarui ketergantungan aplikasi padaflink-connector-kinesis. Jika Anda menggunakan Maven sebagai alat pembuatan proyek Anda, ikuti. Perbarui ketergantungan Maven Jika Anda menggunakan Gradle, ikutiMemperbarui ketergantungan Gradle .

• Paket ulang aplikasi.

• Unggah ke bucket Amazon S3.

• Kirim ulang permintaan aplikasi buat/perbarui dengan aplikasi yang direvisi yang baru saja diunggah ke bucket Amazon S3.

• Jika Anda terus melihat pesan kesalahan yang sama, periksa kembali dependensi aplikasi Anda. Jika masalah berlanjut, silakan buat tiket dukungan.

Perbarui ketergantungan Maven

1. Buka proyekpom.xml.

2. Temukan dependensi proyek. Mereka terlihat seperti:

   <project>
   
       ...
   
       <dependencies>
   
           ...
   
           <dependency>
               <groupId>org.apache.flink</groupId>
               <artifactId>flink-connector-kinesis</artifactId>
           </dependency>
   
           ...
   
       </dependencies>
   
       ...
   
   </project>

3. Perbarui flink-connector-kinesis ke versi yang sama dengan atau lebih baru dari 1.15.2. Misalnya:

   <project>
   
       ...
   
       <dependencies>
   
           ...
   
           <dependency>
               <groupId>org.apache.flink</groupId>
               <artifactId>flink-connector-kinesis</artifactId>
               <version>1.15.2</version>
           </dependency>
   
           ...
   
       </dependencies>
   
       ...
   
   </project>

Memperbarui ketergantungan Gradle

1. Buka proyek build.gradle (atau build.gradle.kts untuk aplikasi Kotlin).

2. Temukan dependensi proyek. Mereka terlihat seperti:

   ...
   
   dependencies {
   
       ...
   
       implementation("org.apache.flink:flink-connector-kinesis")
   
       ...
   
   }
   
   ...

3. Perbarui flink-connector-kinesis ke versi yang sama dengan atau lebih baru dari 1.15.2. Misalnya:

   ...
   
   dependencies {
   
       ...
   
       implementation("org.apache.flink:flink-connector-kinesis:1.15.2")
   
       ...
   
   }
   
   ...