Atualize aplicativos usando atualizações de versão in-loco para o Apache Flink - Managed Service for Apache Flink
Antes da atualização: atualize seu aplicativo Apache Flink

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

Atualize aplicativos usando atualizações de versão in-loco para o Apache Flink

Antes de começar, recomendamos que você assista a este vídeo: Atualizações de versão in-loco.

Para realizar atualizações de versão in-loco para o Apache Flink, você pode usar o AWS CLI,, AWS CloudFormation, AWS SDK ou o. AWS Management Console Você pode usar esse recurso com qualquer aplicativo existente que você usa com o Managed Service for Apache Flink em um estado READY ouRUNNING. Ele usa o UpdateApplication API para adicionar a capacidade de alterar o tempo de execução do Flink.

Antes da atualização: atualize seu aplicativo Apache Flink

Ao escrever seus aplicativos Flink, você os agrupa com suas dependências em um aplicativo JAR e os carrega em seu bucket do Amazon JAR S3. A partir daí, o Amazon Managed Service para Apache Flink executa o trabalho no novo tempo de execução do Flink que você selecionou. Talvez seja necessário atualizar seus aplicativos para obter compatibilidade com o tempo de execução do Flink para o qual você deseja fazer o upgrade. Pode haver inconsistências entre as versões do Flink que fazem com que a atualização da versão falhe. Geralmente, isso ocorre com conectores para fontes (entrada) ou destinos (coletores, saída) e dependências do Scala. O Flink 1.15 e versões posteriores no Managed Service for Apache Flink são independentes de Scala, e você JAR deve conter a versão do Scala que você planeja usar.

Para atualizar seu aplicativo

  1. Leia os conselhos da comunidade Flink sobre como atualizar aplicativos com o estado. Consulte Atualização de aplicativos e versões do Flink.

  2. Leia a lista de problemas e limitações conhecidos. Consulte Precauções e problemas conhecidos com atualizações de aplicativos.

  3. Atualize suas dependências e teste seus aplicativos localmente. Essas dependências normalmente são:

    1. O tempo de execução do Flink e. API

    2. Conectores recomendados para o novo tempo de execução do Flink. Você pode encontrá-los nas versões Release para o tempo de execução específico para o qual deseja atualizar.

    3. Scala — O Apache Flink é independente de Scala, começando com e incluindo o Flink 1.15. Você deve incluir as dependências do Scala que deseja usar em seu aplicativo. JAR

  4. Crie um novo aplicativo JAR no arquivo zip e faça o upload para o Amazon S3. Recomendamos que você use um nome diferente do JAR /zipfile. anterior Se precisar reverter, você usará essas informações.

  5. Se você estiver executando aplicativos com estado, é altamente recomendável que você tire um instantâneo do seu aplicativo atual. Isso permite reverter de forma contínua se você encontrar problemas durante ou após a atualização.