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

1. Abra pom.xml do projeto.

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

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

1. Abra build.gradle do projeto (ou build.gradle.kts para aplicativos Kotlin).

2. Encontre as dependências do projeto. Elas se parecem com:

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

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