Aplicaciones con conectores Kinesis no compatibles - Managed Service para Apache Flink
Error de rechazo Pasos para solucionarlo

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

  1. Abra el pom.xml del proyecto.

  2. Encuentre las dependencias del proyecto. Aparecen así:

    <project>

    ...

    <dependencies>

        ...

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

        ...

    </dependencies>

    ...

</project>

  3. 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

  1. Abra el build.gradle del proyecto (o build.gradle.kts para las aplicaciones de Kotlin).

  2. Encuentre las dependencias del proyecto. Aparecen así:

    ...

dependencies {

    ...

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

    ...

}

...

  3. 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")

    ...

}

...