Anwendungen mit nicht unterstützten Kinesis-Konnektoren

Managed Service for Apache Flink for Apache Flink Version 1.15 oder höher lehnt automatisch den Start oder die Aktualisierung von Anwendungen ab, wenn sie nicht unterstützte Kinesis Connector-Versionen (vor Version 1.15.2) verwenden, die in Anwendungen oder Archiven gebündelt sind (). JARs ZIP

Ablehnungsfehler

Sie erhalten folgende Fehlermeldung, wenn Sie Aufrufe zum Erstellen und Aktualisieren von Anwendungen übermitteln:

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

Schritte zur Behebung

• Aktualisieren Sie die Abhängigkeit der Anwendung von flink-connector-kinesis. Wenn Sie Maven als Build-Tool für Ihr Projekt verwenden, folgen Sie Aktualisieren einer Maven-Abhängigkeit . Wenn Sie Gradle verwenden, folgen Sie Aktualisieren einer Gradle-Abhängigkeit .

• Verpacken Sie die Anwendung erneut.

• Laden Sie sie in einen Amazon-S3-Bucket hoch.

• Reichen Sie die Anfrage zum Erstellen/Aktualisieren der Anwendung erneut mit der überarbeiteten Anwendung ein, die gerade in den Amazon-S3-Bucket hochgeladen wurde.

• Wenn Sie weiterhin dieselbe Fehlermeldung erhalten, überprüfen Sie Ihre Anwendungsabhängigkeiten erneut. Wenn das Problem weiterhin besteht, erstellen Sie bitte ein Support-Ticket.

Aktualisieren einer Maven-Abhängigkeit

1. Öffnen Sie die pom.xml des Projekts.

2. Finden Sie die Abhängigkeiten des Projekts. Sie sehen etwa so aus:

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

3. Aktualisieren Sie flink-connector-kinesis auf Version 1.15.2 oder neuer. Zum Beispiel:

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

Aktualisieren einer Gradle-Abhängigkeit

1. Öffnen Sie die build.gradle des Projekts (oder build.gradle.kts für Kotlin-Anwendungen).

2. Finden Sie die Abhängigkeiten des Projekts. Sie sehen etwa so aus:

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

3. Aktualisieren Sie flink-connector-kinesis auf Version 1.15.2 oder neuer. Zum Beispiel:

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