Applicazioni con connettori Kinesis non supportati

Managed Service for Apache Flink per Apache Flink versione 1.15 o successiva rifiuterà automaticamente l'avvio o l'aggiornamento delle applicazioni se utilizzano versioni di Kinesis Connector non supportate (precedenti alla versione 1.15.2) incluse nell'applicazione o negli archivi (). JARs ZIP

Errore di rifiuto

Verrà visualizzato il seguente errore quando si inviano chiamate di creazione/aggiornamento all'applicazione tramite:

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

Come risolvere il problema

• Aggiorna la dipendenza dell'applicazione da flink-connector-kinesis. Se utilizzi Maven come strumento di compilazione del progetto, segui Aggiorna una dipendenza da Maven . Se utilizzi Gradle, segui Aggiorna una dipendenza da Gradle .

• Crea di nuovo un pacchetto con l'applicazione.

• Carica oggetti in un bucket Amazon S3.

• Invia nuovamente la richiesta di creazione/aggiornamento con l'applicazione modificata appena caricata nel bucket Amazon S3.

• Se il messaggio di errore continua a ripresentarsi, controlla nuovamente le dipendenze dell'applicazione. Crea un ticket per richiedere assistenza nel caso in cui il problema persista.

Aggiorna una dipendenza da Maven

1. Apri il file pom.xml del progetto.

2. Individua le dipendenze del progetto. Hanno questo aspetto:

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

3. Aggiorna flink-connector-kinesis a una versione uguale o successiva alla 1.15.2. Per esempio:

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

Aggiorna una dipendenza da Gradle

1. Apri il build.gradle del progetto (o build.gradle.kts per le applicazioni Kotlin).

2. Individua le dipendenze del progetto. Hanno questo aspetto:

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

3. Aggiorna flink-connector-kinesis a una versione uguale o successiva alla 1.15.2. Per esempio:

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