Amazon Managed Service para Apache Flink Amazon se denominaba anteriormente Amazon Kinesis Data Analytics para Apache Flink.
Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.
Aplicaciones con conectores Kinesis no compatibles
Managed Service for Apache Flink for Apache Flink versión 1.15 o posterior rechazará automáticamente el inicio o la actualización de las aplicaciones si utilizan versiones no compatibles de Kinesis Connector (anteriores a la versión 1.15.2) incluidas en la aplicación o los archivos (). JARs ZIP
Error de rechazo
Aparecerá el siguiente error al enviar las llamadas de creación o actualización de la aplicación:
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
Pasos para solucionarlo
Actualice la dependencia de la aplicación en
flink-connector-kinesis
. Si utiliza Maven como la herramienta de creación de su proyecto, siga Actualización de una dependencia de Maven . Si usa Gradle, siga Actualización de una dependencia de Gradle .Vuelva a empaquetar la aplicación.
Cargue en un bucket de Amazon S3.
Vuelva a enviar la solicitud de creación o actualización de la aplicación con la aplicación modificada que se acaba de cargar en el bucket de Amazon S3.
Si sigue apareciendo el mismo mensaje de error, vuelva a comprobar las dependencias de la aplicación. Si el problema persiste, cree una inidencia de soporte técnicio.
Actualización de una dependencia de Maven
Abra el
pom.xml
del proyecto.Encuentre las dependencias del proyecto. Aparecen así:
<project> ... <dependencies> ... <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-kinesis</artifactId> </dependency> ... </dependencies> ... </project>
Actualice
flink-connector-kinesis
a una versión igual o posterior a la 1.15.2. Por ejemplo:<project> ... <dependencies> ... <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-kinesis</artifactId> <version>1.15.2</version> </dependency> ... </dependencies> ... </project>
Actualización de una dependencia de Gradle
Abra el
build.gradle
del proyecto (obuild.gradle.kts
para las aplicaciones de Kotlin).Encuentre las dependencias del proyecto. Aparecen así:
... dependencies { ... implementation("org.apache.flink:flink-connector-kinesis") ... } ...
Actualice
flink-connector-kinesis
a una versión igual o posterior a la 1.15.2. Por ejemplo:... dependencies { ... implementation("org.apache.flink:flink-connector-kinesis:1.15.2") ... } ...