Anteriormente, o Amazon Managed Service for Apache Flink era conhecido como Amazon Kinesis Data Analytics for Apache Flink.
As traduções são geradas por tradução automática. Em caso de conflito entre o conteúdo da tradução e da versão original em inglês, a versão em inglês prevalecerá.
Aplicativos com conectores Kinesis não compatíveis
O Managed Service for Apache Flink for Apache Flink versão 1.15 ou posterior rejeitará automaticamente a inicialização ou atualização dos aplicativos se eles estiverem usando versões incompatíveis do Kinesis Connector (pré-versão 1.15.2) agrupadas em JARs ou arquivos de aplicativos (ZIP).
Erro de rejeição
Você verá o seguinte erro ao enviar chamadas de criação e atualização do aplicativo por meio de:
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
Etapas para remediar
Atualize a dependência do aplicativo em
flink-connector-kinesis
. Se você estiver usando o Maven como ferramenta de construção do seu projeto, siga Atualizar uma dependência do Maven . Se você estiver usando o Gradle, siga Atualizar uma dependência do Gradle .Reempacote o aplicativo.
Faça upload para um bucket do Amazon S3.
Reenvie a solicitação de criação/atualização do aplicativo com o aplicativo revisado que acabou de ser carregado no bucket do Amazon S3.
Se você continuar vendo a mesma mensagem de erro, verifique novamente as dependências do aplicativo. Se o problema persistir, crie um ticket de suporte.
Atualizar uma dependência do Maven
Abra
pom.xml
do projeto.Encontre as dependências do projeto. Elas se parecem com:
<project> ... <dependencies> ... <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-kinesis</artifactId> </dependency> ... </dependencies> ... </project>
Atualize
flink-connector-kinesis
para uma versão igual ou posterior à 1.15.2. Por exemplo:<project> ... <dependencies> ... <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-kinesis</artifactId> <version>1.15.2</version> </dependency> ... </dependencies> ... </project>
Atualizar uma dependência do Gradle
Abra
build.gradle
do projeto (oubuild.gradle.kts
para aplicativos Kotlin).Encontre as dependências do projeto. Elas se parecem com:
... dependencies { ... implementation("org.apache.flink:flink-connector-kinesis") ... } ...
Atualize
flink-connector-kinesis
para uma versão igual ou posterior à 1.15.2. Por exemplo:... dependencies { ... implementation("org.apache.flink:flink-connector-kinesis:1.15.2") ... } ...